Uploaded image for project: 'WildFly'
  1. WildFly
  2. WFLY-5480

SPEC JMS 2007 benchmark fails with AMQ214013: Failed to decode packet

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Closed (View Workflow)
    • Priority: Blocker
    • Resolution: Done
    • Affects Version/s: None
    • Fix Version/s: 10.0.0.Final
    • Component/s: JMS
    • Labels:
      None
    • Steps to Reproduce:
      Hide

      How to reproduce:

      • Download and unzip attached specjms2007.zip benchamark
      • set correct path to client libs in specjms2007/config/default.env
      • run ant clean jar in specjms2007/
      • start eap7 with one of attached configs
      • run ant describe jms-setup in specjms2007/
      • run ant startController in specjms2007/
      • run in second terminal ant -d startSatellite -Dcontroller.host=127.0.0.1 -Dnode.name=127.0.0.1 in specjms2007/
      • when benchmark finishes, check specjms-result.html in latest direcotry in specjms2007/output/ if test passes, big rectangle on top of web site should be completely green (no red)
      • if you want to change load edit org.spec.jms.horizontal.BASE in specjms2007/config/horizontal.properties
      Show
      How to reproduce: Download and unzip attached specjms2007.zip benchamark set correct path to client libs in specjms2007/config/default.env run ant clean jar in specjms2007/ start eap7 with one of attached configs run ant describe jms-setup in specjms2007/ run ant startController in specjms2007/ run in second terminal ant -d startSatellite -Dcontroller.host=127.0.0.1 -Dnode.name=127.0.0.1 in specjms2007/ when benchmark finishes, check specjms-result.html in latest direcotry in specjms2007/output/ if test passes, big rectangle on top of web site should be completely green (no red) if you want to change load edit org.spec.jms.horizontal.BASE in specjms2007/config/horizontal.properties

      Description

      But I have another problem, when I removed trace logs from config I'm not able to run benchmark on localhost to the end, because clients starts getting :
      AMQ214013: Failed to decode packet
      java.lang.IndexOutOfBoundsException: readerIndex: 2130706436 (expected: 0 <= readerIndex <= writerIndex(2943))
      at io.netty.buffer.AbstractByteBuf.readerIndex(AbstractByteBuf.java:73)
      at io.netty.buffer.WrappedByteBuf.readerIndex(WrappedByteBuf.java:99)
      at org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper.readerIndex(ChannelBufferWrapper.java:405)
      at org.apache.activemq.artemis.core.message.impl.MessageImpl.decode(MessageImpl.java:1052)
      at org.apache.activemq.artemis.core.message.impl.MessageImpl.decodeFromBuffer(MessageImpl.java:459)
      at org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionReceiveMessage.decode(SessionReceiveMessage.java:94)
      at org.apache.activemq.artemis.core.protocol.ClientPacketDecoder.decode(ClientPacketDecoder.java:42)
      at org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:371)
      at org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl$DelegatingBufferHandler.bufferReceived(ClientSessionFactoryImpl.java:1374)
      at org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:73)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
      at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
      at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
      at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
      at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
      at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
      at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteCha
      nnel.java:131)
      at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
      at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
      at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
      at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
      at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
      at java.lang.Thread.run(Thread.java:745)
      and
      Thread-9 (ActiveMQ-client-global-threads-1266561810): Uncaught exception.
      java.lang.NumberFormatException: null
      at java.lang.Integer.parseInt(Integer.java:542)
      at java.lang.Integer.valueOf(Integer.java:766)
      at org.apache.activemq.artemis.utils.TypedProperties.getIntProperty(TypedProperties.java:280)
      at org.apache.activemq.artemis.core.message.impl.MessageImpl.getIntProperty(MessageImpl.java:811)
      at org.apache.activemq.artemis.jms.client.ActiveMQMessage.getIntProperty(ActiveMQMessage.java:578)
      at org.spec.jms.agents.SPECWorkerThread.receivedMessage(SPECWorkerThread.java:849)
      at org.spec.jms.agents.SPECWorkerThread.onMessage(SPECWorkerThread.java:820)
      at org.apache.activemq.artemis.jms.client.JMSMessageListenerWrapper.onMessage(JMSMessageListenerWrapper.java:100)
      at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.callOnMessage(ClientConsumerImpl.java:1089)
      at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.access$400(ClientConsumerImpl.java:47)
      at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl$Runner.run(ClientConsumerImpl.java:1224)
      at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$1.run(OrderedExecutorFactory.java:105)
      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)
      Thread-3 (ActiveMQ-client-global-threads-1266561810): Uncaught exception.
      javax.jms.IllegalStateException: AMQ119027: Could not find reference on consumer ID=0, messageId = 104,833 queue = 127\.0\.0\.1_VM1_SPAgent7_0.SP_CallForOffersEH_7_EHID_1PF0
      at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:410)
      at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.sendACK(ActiveMQSessionContext.java:461)
      at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.acknowledge(ClientSessionImpl.java:765)
      at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.doAck(ClientConsumerImpl.java:1212)
      at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.flushAcks(ClientConsumerImpl.java:830)
      at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.flushAcks(ClientSessionImpl.java:1852)
      at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.commit(ClientSessionImpl.java:501)
      at org.apache.activemq.artemis.core.client.impl.DelegatingSession.commit(DelegatingSession.java:159)
      at org.apache.activemq.artemis.jms.client.ActiveMQSession.commit(ActiveMQSession.java:218)
      at org.spec.jms.eventhandler.sp.SP_CallForOffersEH.handleMessage(SP_CallForOffersEH.java:306)
      at org.spec.jms.agents.SPECWorkerThread.onMessage(SPECWorkerThread.java:821)
      at org.apache.activemq.artemis.jms.client.JMSMessageListenerWrapper.onMessage(JMSMessageListenerWrapper.java:100)
      at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.callOnMessage(ClientConsumerImpl.java:1089)
      at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.access$400(ClientConsumerImpl.java:47)
      at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl$Runner.run(ClientConsumerImpl.java:1224)
      at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$1.run(OrderedExecutorFactory.java:105)
      at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      at java.util.concurrent.ThreadPoolExecut

        Attachments

          Issue Links

            Activity

              People

              Assignee:
              jmesnil Jeff Mesnil
              Reporter:
              okalman Ondřej Kalman (Inactive)
              Votes:
              3 Vote for this issue
              Watchers:
              12 Start watching this issue

                Dates

                Created:
                Updated:
                Resolved: