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

"Error during message dispatch" when receiving a message sent from OpenWire with wireFormat.tightEncodingEnabled=false

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • AMQ 7.1.0.GA
    • AMQ 7.0.2.GA
    • openwire-protocol
    • None
    • Hide

      Send a message using OpenWire, set wireFormat.tightEncodingEnabled=false and the reply-to address.

      java -jar aoc.jar sender --log-msgs dict --broker $brokerUrl --address $address --conn-tight-encoding-ena false --msg-reply-to aReplyToQueue

      Attempt to receive the message

      java -jar aoc.jar receiver --log-msgs dict --broker $brokerUrl --address $address --count 1

      Message is not received and broker prints the exception in description.

      Alternatively, leave out the reply-to address and perorm the two steps above.

      The message is received, but it is missing Message ID.

      Show
      Send a message using OpenWire, set wireFormat.tightEncodingEnabled=false and the reply-to address. java -jar aoc.jar sender --log-msgs dict --broker $brokerUrl --address $address --conn-tight-encoding-ena false --msg-reply-to aReplyToQueue Attempt to receive the message java -jar aoc.jar receiver --log-msgs dict --broker $brokerUrl --address $address --count 1 Message is not received and broker prints the exception in description. Alternatively, leave out the reply-to address and perorm the two steps above. The message is received, but it is missing Message ID.
    • AMQ Broker 7.1 Sprint 2

      As described in Reproduction steps, two undesirable outcomes can happen. Either an exception is printed from broker, or the message received is missing Message ID.

      The broker exception is

      19:21:40,078 WARN  [org.apache.activemq.artemis.core.server] Error during message dispatch: java.lang.NullPointerException
        at org.apache.activemq.command.ActiveMQDestination.setPhysicalName(ActiveMQDestination.java:239) [activemq-client-5.14.5.jar:5.14.5]
        at org.apache.activemq.openwire.v12.ActiveMQDestinationMarshaller.tightUnmarshal(ActiveMQDestinationMarshaller.java:54) [activemq-client-5.14.5.jar:5.14.5]
        at org.apache.activemq.openwire.v12.ActiveMQQueueMarshaller.tightUnmarshal(ActiveMQQueueMarshaller.java:66) [activemq-client-5.14.5.jar:5.14.5]
        at org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:365) [activemq-client-5.14.5.jar:5.14.5]
        at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:201) [activemq-client-5.14.5.jar:5.14.5]
        at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:752) [artemis-openwire-protocol-2.3.0-SNAPSHOT.jar:]
        at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:429) [artemis-openwire-protocol-2.3.0-SNAPSHOT.jar:]
        at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:224) [artemis-openwire-protocol-2.3.0-SNAPSHOT.jar:]
        at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:250) [artemis-openwire-protocol-2.3.0-SNAPSHOT.jar:]
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1088) [artemis-server-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:460) [artemis-server-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2712) [artemis-server-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2191) [artemis-server-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1900(QueueImpl.java:102) [artemis-server-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2949) [artemis-server-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.utils.actors.ProcessorBase$ExecutorTask.run(ProcessorBase.java:53) [artemis-commons-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_131]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_131]
        at java.lang.Thread.run(Thread.java:748) [rt.jar:1.8.0_131]

java.lang.NullPointerException
        at org.apache.activemq.command.ActiveMQDestination.setPhysicalName(ActiveMQDestination.java:239)
        at org.apache.activemq.openwire.v12.ActiveMQDestinationMarshaller.tightUnmarshal(ActiveMQDestinationMarshaller.java:54)
        at org.apache.activemq.openwire.v12.ActiveMQQueueMarshaller.tightUnmarshal(ActiveMQQueueMarshaller.java:66)
        at org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:365)
        at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:201)
        at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:752)
        at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:429)
        at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:224)
        at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:250)
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1088)
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:460)
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2712)
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2191)
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1900(QueueImpl.java:102)
        at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2949)
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42)
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31)
        at org.apache.activemq.artemis.utils.actors.ProcessorBase$ExecutorTask.run(ProcessorBase.java:53)
        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:748)
19:21:40,279 WARN  [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session 8ca3a0cf-754b-11e7-90d9-185e0fec8ce5
19:21:40,279 WARN  [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session 8ca3a0cf-754b-11e7-90d9-185e0fec8ce5
19:21:40,279 WARN  [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session ID:nixos-34849-1501435290148-53:1:-1
19:21:40,280 WARN  [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session ID:nixos-34849-1501435290148-53:1:-1
19:21:40,587 WARN  [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session 8ce2a5a2-754b-11e7-90d9-185e0fec8ce5
19:21:40,587 WARN  [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session 8ce2a5a2-754b-11e7-90d9-185e0fec8ce5
19:21:40,587 WARN  [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session ID:nixos-34849-1501435290148-55:1:-1
19:21:40,587 WARN  [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session ID:nixos-34849-1501435290148-55:1:-1
19:21:40,659 WARN  [org.apache.activemq.artemis.core.server] Error during message dispatch: java.lang.NullPointerException
        at org.apache.activemq.command.ActiveMQDestination.setPhysicalName(ActiveMQDestination.java:239) [activemq-client-5.14.5.jar:5.14.5]
        at org.apache.activemq.openwire.v12.ActiveMQDestinationMarshaller.tightUnmarshal(ActiveMQDestinationMarshaller.java:54) [activemq-client-5.14.5.jar:5.14.5]
        at org.apache.activemq.openwire.v12.ActiveMQQueueMarshaller.tightUnmarshal(ActiveMQQueueMarshaller.java:66) [activemq-client-5.14.5.jar:5.14.5]
        at org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:365) [activemq-client-5.14.5.jar:5.14.5]
        at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:201) [activemq-client-5.14.5.jar:5.14.5]
        at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:752) [artemis-openwire-protocol-2.3.0-SNAPSHOT.jar:]
        at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:429) [artemis-openwire-protocol-2.3.0-SNAPSHOT.jar:]
        at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:224) [artemis-openwire-protocol-2.3.0-SNAPSHOT.jar:]
        at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:250) [artemis-openwire-protocol-2.3.0-SNAPSHOT.jar:]
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1088) [artemis-server-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:460) [artemis-server-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2712) [artemis-server-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2191) [artemis-server-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1900(QueueImpl.java:102) [artemis-server-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2949) [artemis-server-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at org.apache.activemq.artemis.utils.actors.ProcessorBase$ExecutorTask.run(ProcessorBase.java:53) [artemis-commons-2.3.0-SNAPSHOT.jar:2.3.0-SNAPSHOT]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_131]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_131]
        at java.lang.Thread.run(Thread.java:748) [rt.jar:1.8.0_131]

java.lang.NullPointerException
        at org.apache.activemq.command.ActiveMQDestination.setPhysicalName(ActiveMQDestination.java:239)
        at org.apache.activemq.openwire.v12.ActiveMQDestinationMarshaller.tightUnmarshal(ActiveMQDestinationMarshaller.java:54)
        at org.apache.activemq.openwire.v12.ActiveMQQueueMarshaller.tightUnmarshal(ActiveMQQueueMarshaller.java:66)
        at org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:365)
        at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:201)
        at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:752)
        at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:429)
        at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:224)
        at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:250)
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1088)
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:460)
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2712)
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2191)
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1900(QueueImpl.java:102)
        at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2949)
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42)
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31)
        at org.apache.activemq.artemis.utils.actors.ProcessorBase$ExecutorTask.run(ProcessorBase.java:53)
        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:748)
19:21:40,863 WARN  [org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, clearing up resources for session 8cfcbd56-754b-11e7-90d9-185e0fec8ce5
19:21:40,864 WARN  [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for session 8cfcbd56-754b-11e7-90d9-185e0fec8ce5

      Both AMQ 7 Broker and ActiveMQ Artemis are affected.

            gaohoward Howard Gao
            jdanek@redhat.com Jiri Daněk
            Michal Toth Michal Toth
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

              Created:
              Updated:
              Resolved: