org.jberet.support.io.JmsReaderWriterTest failed with netty version 4.0.28 or later

The netty version in JBeret as of 5/20 is 4.0.26.Final (working). If upgrading to 4.0.28 or later (the latest version is currently 4.0.33.Final), org.jberet.support.io.JmsReaderWriterTest (3 tests failed).

mvn install -Dtest=org.jberet.support.io.JmsReaderWriterTest

Running org.jberet.support.io.JmsReaderWriterTest
May 19, 2016 10:22:48 PM org.jboss.weld.bootstrap.WeldStartup <clinit>
INFO: WELD-000900: 2.3.4 (Final)
May 19, 2016 10:22:48 PM org.jboss.weld.environment.deployment.discovery.DiscoveryStrategyFactory create
INFO: WELD-ENV-000020: Using jandex for bean discovery
May 19, 2016 10:22:48 PM org.jboss.weld.bootstrap.WeldStartup startContainer
INFO: WELD-000101: Transactional services not available. Injection of @Inject UserTransaction not available. Transactional observers will be invoked synchronously.
May 19, 2016 10:22:49 PM org.jboss.weld.environment.se.WeldContainer initialize
INFO: WELD-ENV-002003: Weld SE container STATIC_INSTANCE initialized
May 19, 2016 10:22:49 PM org.hornetq.core.server.impl.HornetQServerImpl start
INFO: HQ221000: live server is starting with configuration HornetQ Configuration (clustered=false,backup=false,sharedStore=true,journalDirectory=target/data/journal,bindingsDirectory=data/bindings,largeMessagesDirectory=data/largemessages,pagingDirectory=data/paging)
May 19, 2016 10:22:49 PM org.hornetq.core.server.impl.HornetQServerImpl initialisePart1
INFO: HQ221045: libaio is not available, switching the configuration into NIO
May 19, 2016 10:22:49 PM org.hornetq.core.server.impl.HornetQServerImpl initialisePart1
WARN: HQ222007: Security risk! HornetQ is running with the default cluster admin user and default password. Please see the HornetQ user guide, cluster chapter, for instructions on how to change this.
May 19, 2016 10:22:49 PM org.hornetq.core.remoting.server.impl.RemotingServiceImpl <init>
INFO: HQ221043: Adding protocol support CORE
May 19, 2016 10:22:50 PM org.hornetq.core.server.impl.HornetQServerImpl deployQueue
INFO: HQ221003: trying to deploy queue jms.queue.queue1
May 19, 2016 10:22:50 PM org.hornetq.core.remoting.impl.netty.NettyAcceptor start
INFO: HQ221020: Started Netty Acceptor version 4.0.33.Final localhost:5445
May 19, 2016 10:22:50 PM org.hornetq.core.server.impl.HornetQServerImpl$SharedNothingLiveActivation run
INFO: HQ221007: Server is now live
May 19, 2016 10:22:50 PM org.hornetq.core.server.impl.HornetQServerImpl start
INFO: HQ221001: HornetQ Server version 2.4.7.Final (2.4.7.Final, 124) [c7a8073e-1e30-11e6-8eb5-33a36160472e]
Started Embedded JMS Server
May 19, 2016 10:22:50 PM org.jberet.support.io.CsvItemReader open
INFO: JBERET060501: Opening resource IBM_unadjusted.txt in class org.jberet.support.io.CsvItemReader
May 19, 2016 10:22:50 PM org.jberet.support.io.CsvItemReader close
INFO: JBERET060502: Closing resource IBM_unadjusted.txt in class org.jberet.support.io.CsvItemReader
May 19, 2016 10:22:50 PM org.jberet.support.io.CsvItemWriter open
INFO: JBERET060501: Opening resource /Users/cfang/dev/jsr352/jberet-support/target/tmp/readIBMStockTradeCsvWriteJmsMapType.out in class org.jberet.support.io.CsvItemWriter
May 19, 2016 10:22:50 PM org.hornetq.core.server.impl.QueueImpl proceedDeliver
WARN: HQ222151: removing consumer which did not handle a message, consumer=ServerConsumerImpl [id=0, filter=null, binding=LocalQueueBinding [address=jms.queue.queue1, queue=QueueImpl[name=jms.queue.queue1, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c7a8073e-1e30-11e6-8eb5-33a36160472e]]@767f5c, filter=null, name=jms.queue.queue1, clusterName=jms.queue.queue1c7a8073e-1e30-11e6-8eb5-33a36160472e]], message=Reference[4]:RELIABLE:ServerMessage[messageID=4,durable=true,userID=c0212fe0-1e31-11e6-b670-3fb5d68e26c3,priority=4, bodySize=383,expiration=0, durable=true, address=jms.queue.queue1,properties=TypedProperties[__HQ_CID=c01967ad-1e31-11e6-b670-3fb5d68e26c3]]@1165291830
java.lang.IndexOutOfBoundsException: writerIndex(382) + minWritableBytes(8) exceeds maxCapacity(383): SlicedAbstractByteBuf(ridx: 0, widx: 382, cap: 383/383, unwrapped: UnpooledUnsafeHeapByteBuf(ridx: 383, widx: 383, cap: 464))
at io.netty.buffer.AbstractByteBuf.ensureWritable0(AbstractByteBuf.java:259)
at io.netty.buffer.AbstractByteBuf.writeLong(AbstractByteBuf.java:807)
at io.netty.buffer.WrappedByteBuf.writeLong(WrappedByteBuf.java:583)
at org.hornetq.core.buffers.impl.ChannelBufferWrapper.writeLong(ChannelBufferWrapper.java:618)
at org.hornetq.core.protocol.core.impl.wireformat.SessionReceiveMessage.encode(SessionReceiveMessage.java:71)
at org.hornetq.core.protocol.core.impl.ChannelImpl.send(ChannelImpl.java:235)
at org.hornetq.core.protocol.core.impl.ChannelImpl.sendBatched(ChannelImpl.java:210)
at org.hornetq.core.protocol.core.impl.CoreSessionCallback.sendMessage(CoreSessionCallback.java:76)
at org.hornetq.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:970)
at org.hornetq.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:406)
at org.hornetq.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2588)
at org.hornetq.core.server.impl.QueueImpl.deliver(QueueImpl.java:2164)
at org.hornetq.core.server.impl.QueueImpl.access$1300(QueueImpl.java:93)
at org.hornetq.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2971)
at org.hornetq.utils.OrderedExecutorFactory$OrderedExecutor$1.run(OrderedExecutorFactory.java:104)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

...

Results :

Failed tests:
JmsReaderWriterTest.readIBMStockTradeCsvWriteJmsBeanType:117->testRead0:191 expected:<COMPLETED> but was:<FAILED>
JmsReaderWriterTest.readIBMStockTradeCsvWriteJmsListType:137->testRead0:191 expected:<COMPLETED> but was:<FAILED>
Tests in error:
JmsReaderWriterTest.readIBMStockTradeCsvWriteJmsMapType:127->testRead0:192 » IllegalState

Tests run: 3, Failures: 2, Errors: 1, Skipped: 0