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

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major 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.

      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]

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

                Created:
                Updated:
                Resolved: