Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-915

Receiving Text message sent via Core 2.x cannot be received with Core 1.x

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • AMQ 7.1.0.CR2
    • AMQ 7.0.2.GA, AMQ 7.0.3.GA
    • None
    • Hide

      configure EAP to use AMQ7 as remote messaging broker.
      Deploy MDB which will consume messages from its queue.
      Send message to this queue via AMQP client.

      Show
      configure EAP to use AMQ7 as remote messaging broker. Deploy MDB which will consume messages from its queue. Send message to this queue via AMQP client.

    Description

      EAP is used with a remote AMQ7 broker and MDB consumes messages from its queue.
      When AMQP client sends a message to this queue, MDB is not able to consume this message.

      Following error is logged on EAP server:

       AMQ154004: Failed to deliver message: java.lang.IndexOutOfBoundsException: readerIndex(22) + length(40) exceeds writerIndex(58): UnpooledDuplicatedByteBuf(ridx: 22, widx: 58, cap: 104, unwrapped: UnpooledByteBufAllocator$InstrumentedUnpooledUnsafeHeapByteBuf(ridx: 92, widx: 104, cap: 104))
      	at io.netty.buffer.AbstractByteBuf.checkReadableBytes0(AbstractByteBuf.java:1396) [netty-all-4.1.9.Final-redhat-1.jar:4.1.9.Final-redhat-1]
      	at io.netty.buffer.AbstractByteBuf.checkReadableBytes(AbstractByteBuf.java:1383) [netty-all-4.1.9.Final-redhat-1.jar:4.1.9.Final-redhat-1]
      	at io.netty.buffer.AbstractByteBuf.readBytes(AbstractByteBuf.java:850) [netty-all-4.1.9.Final-redhat-1.jar:4.1.9.Final-redhat-1]
      	at io.netty.buffer.AbstractByteBuf.readBytes(AbstractByteBuf.java:858) [netty-all-4.1.9.Final-redhat-1.jar:4.1.9.Final-redhat-1]
      	at io.netty.buffer.WrappedByteBuf.readBytes(WrappedByteBuf.java:649) [netty-all-4.1.9.Final-redhat-1.jar:4.1.9.Final-redhat-1]
      	at org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper.readSimpleStringInternal(ChannelBufferWrapper.java:93) [artemis-commons-1.5.5.008-redhat-1.jar:1.5.5.008-redhat-1]
      	at org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper.readNullableSimpleString(ChannelBufferWrapper.java:73) [artemis-commons-1.5.5.008-redhat-1.jar:1.5.5.008-redhat-1]
      	at org.apache.activemq.artemis.reader.TextMessageUtil.readBodyText(TextMessageUtil.java:37) [artemis-core-client-1.5.5.008-redhat-1.jar:1.5.5.008-redhat-1]
      	at org.apache.activemq.artemis.jms.client.ActiveMQTextMessage.doBeforeReceive(ActiveMQTextMessage.java:112) [artemis-jms-client-1.5.5.008-redhat-1.jar:1.5.5.008-redhat-1]
      	at org.apache.activemq.artemis.ra.inflow.ActiveMQMessageHandler.onMessage(ActiveMQMessageHandler.java:295) [artemis-ra-1.5.5.008-redhat-1.jar:1.5.5.008-redhat-1]
      	at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.callOnMessage(ClientConsumerImpl.java:1001) [artemis-core-client-1.5.5.008-redhat-1.jar:1.5.5.008-redhat-1]
      	at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.access$400(ClientConsumerImpl.java:49) [artemis-core-client-1.5.5.008-redhat-1.jar:1.5.5.008-redhat-1]
      	at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl$Runner.run(ClientConsumerImpl.java:1124) [artemis-core-client-1.5.5.008-redhat-1.jar:1.5.5.008-redhat-1]
      	at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:122) [artemis-commons-1.5.5.008-redhat-1.jar:1.5.5.008-redhat-1]
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_05]
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_05]
      	at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_05]
      
      

      Attachments

        Activity

          People

            csuconic@redhat.com Clebert Suconic
            okalman@redhat.com Ondřej Kalman (Inactive)
            Votes:
            1 Vote for this issue
            Watchers:
            9 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: