Loading...

XML

Word

Printable

Type: Bug
Resolution: Done
Priority: Critical
Fix Version/s: AMQ 7.4.2.GA
Affects Version/s: AMQ 7.4.0.GA
Component/s: amqp-protocol, broker-core, core-protocol
Labels:
- regression

Affects:

Release Notes
GSS Priority:
QE Test Coverage:
+
Release Note Text:
Previously, editing an AMQP message via a divert or server-side interceptor could cause irrecoverable damage to the message body. As a result of this issue, an AMQP client could no longer read the message. This issue is now resolved.
Release Note Status:
Documented as Resolved Issue
Target Release:

AMQ 7.4.2.GA
Upstream Jira:
ARTEMIS-2454
Verified:
Verified in a release
Steps to Reproduce:
Hide

Reproducer attached. The camel-springboot-activemq-consumer-1.0-SNAPSHOT.jar.gz is an executable jar that should run without external dependencies, other than 1.8 JVM version (tested on a host other than the build host). It will try to connect to a localhost broker on 61616.

Directions:

Extract the amq-broker-7.4.0-bin / amq-broker-7.4.1.CR2-bin distribution to a local directory.

Create a broker with:

[user@node1 bin]$ ./artemis create /home/user/amq/containers/741CR1 Creating ActiveMQ Artemis instance at: /home/user/amq/containers/741CR1 --user: is a mandatory property! Please provide the default username: admin --password: is mandatory with this configuration: Please provide the default password: [admin] --allow-anonymous | --require-login: is a mandatory property! Allow anonymous access?, valid values are Y,N,True,False N Auto tuning journal ... done! Your system can make 2.98 writes per millisecond, your journal-buffer-timeout will be 336000 You can now start the broker by executing: "/home/user/amq/containers/741CR1/bin/artemis" run ...

Replace the /home/user/amq/containers/741CR1/etc/broker.xml with the example attached, with configured TEST1 and TEST1.FORWARDED addresses and associated divert

Edit jolokia-access.xml / bootstrap.xml as needed if accessing console remotely

Extract the camel-springboot-activemq-consumer-1.0-SNAPSHOT.jar.gz archive to the same host as the broker

Start the broker with /path/to/broker/bin/artemis run

Start the camel application with java -jar camel-springboot-activemq-consumer-1.0-SNAPSHOT.jar and watch for the line that says "connected to remote Broker: amqp://localhost:61616"

Open the broker console and find the "TEST.QUEUE.0" address (should be created by the camel application) - the underlying queue should have an attached consumer.

Click on the "send" tab to open the send message dialog, select "Plain text" as the message type and enter some text in the text dialog box, then click "Send message"

You should see the app pick up the message and drop it into the TEST1 queue and the routed count increment and see the message count increment in the TEST1.FORWARDED queue

Now open a separate terminal in the broker bin directory and attempt to browse the TEST1.FORWARDED queue

./artemis browser --user admin --password admin --destination TEST1.FORWARDED --verbose

In the client we see:

Executing org.apache.activemq.artemis.cli.commands.messages.Browse browser --user admin --password admin --destination TEST1.FORWARDED --verbose Home::/home/user/amq/amq-broker-7.4.1, Instance::/home/user/amq/containers/741CR1 Consumer:: filter = null Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 trying to browse 1000 messages Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 browsed: 0 messages Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 Browser thread finished

In the broker log (depending on version), we see:

2019-08-24 11:26:10,775 ERROR [org.apache.activemq.artemis.core.server] AMQ224046: Exception while browser handled from Reference[36]:RELIABLE:AMQPMessage [durable=true, messageID=36, address=TEST1.FORWARDED, size=364, applicationProperties=ApplicationProperties{{breadcrumbId=queue_TEST.QUEUE.0_null, CamelJmsDeliveryMode=2}}, properties=Properties{messageId=ID:88503c13-148d-434b-a2e0-9292a24af2ba:1:1:1-1, userId=null, to='TEST1.FORWARDED', subject='null', replyTo='null', correlationId=null, contentType=null, contentEncoding=null, absoluteExpiryTime=null, creationTime=Sat Aug 24 11:01:37 EDT 2019, groupId='null', groupSequence=null, replyToGroupId='null'}, extraProperties = TypedProperties[_AMQ_AD=TEST1.FORWARDED]]: java.lang.RuntimeException at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:706) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback.sendMessage(CoreSessionCallback.java:123) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1145) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:504) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl$BrowserDeliverer.run(ServerConsumerImpl.java:1461) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_222] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_222] at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] Caused by: java.lang.NullPointerException at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.scanForMessageSection(AMQPMessage.java:357) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.getBody(AMQPMessage.java:319) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:703) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] ... 10 more 2019-08-24 11:26:10,780 WARN [org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage] null: java.lang.NullPointerException at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.scanForMessageSection(AMQPMessage.java:357) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.getBody(AMQPMessage.java:319) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:703) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback.sendMessage(CoreSessionCallback.java:123) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1145) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:504) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl$BrowserDeliverer.run(ServerConsumerImpl.java:1461) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_222] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_222] at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] 2019-08-24 11:26:10,780 ERROR [org.apache.activemq.artemis.core.server] AMQ224046: Exception while browser handled from Reference[45]:RELIABLE:AMQPMessage [durable=true, messageID=45, address=TEST1.FORWARDED, size=358, applicationProperties=ApplicationProperties{{breadcrumbId=queue_TEST.QUEUE.0_null, CamelJmsDeliveryMode=2}}, properties=Properties{messageId=ID:88503c13-148d-434b-a2e0-9292a24af2ba:1:1:2-1, userId=null, to='TEST1.FORWARDED', subject='null', replyTo='null', correlationId=null, contentType=null, contentEncoding=null, absoluteExpiryTime=null, creationTime=Sat Aug 24 11:18:53 EDT 2019, groupId='null', groupSequence=null, replyToGroupId='null'}, extraProperties = TypedProperties[_AMQ_AD=TEST1.FORWARDED]]: java.lang.RuntimeException at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:706) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback.sendMessage(CoreSessionCallback.java:123) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1145) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:504) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl$BrowserDeliverer.run(ServerConsumerImpl.java:1461) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_222] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_222] at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] Caused by: java.lang.NullPointerException at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.scanForMessageSection(AMQPMessage.java:357) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.getBody(AMQPMessage.java:319) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:703) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] ... 10 more

Now try with --protocol amqp specified:

/artemis browser --user admin --password admin --destination TEST1.FORWARDED --verbose --protocol amqp Executing org.apache.activemq.artemis.cli.commands.messages.Browse browser --user admin --password admin --destination TEST1.FORWARDED --verbose --protocol amqp Home::/home/user/amq/amq-broker-7.4.1, Instance::/home/user/amq/containers/741CR1 Consumer:: filter = null 2019-08-24 11:29:36,514 INFO [org.apache.qpid.jms.sasl.SaslMechanismFinder] Best match for SASL auth was: SASL-PLAIN 2019-08-24 11:29:36,563 WARN [org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder] Open of resource:(JmsConnectionInfo { ID:c723999e-9e4c-45ad-99bb-13bd6f441bfb:1, configuredURI = amqp://localhost:61616, connectedURI = null }) failed: Open failed unexpectedly. 2019-08-24 11:29:36,573 INFO [org.apache.qpid.jms.sasl.SaslMechanismFinder] Best match for SASL auth was: SASL-PLAIN 2019-08-24 11:29:36,600 INFO [org.apache.qpid.jms.JmsConnection] Connection ID:4bc04ad2-4322-4238-8594-1d67e37081b0:2 connected to remote Broker: amqp://localhost:61616 Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 trying to browse 1000 messages Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 browsing THIS IS A GENERIC TEST MESSAGE ...JmsTextMessage { org.apache.qpid.jms.provider.amqp.message.AmqpJmsTextMessageFacade@585a1911 } Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 browsing SECOND TEST TEXT MESSAGE ...JmsTextMessage { org.apache.qpid.jms.provider.amqp.message.AmqpJmsTextMessageFacade@69003269 } Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 browsed: 2 messages Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 Browser thread finished

I have also attached the camel route code, in case it is needed.
Show
Reproducer attached. The camel-springboot-activemq-consumer-1.0-SNAPSHOT.jar.gz is an executable jar that should run without external dependencies, other than 1.8 JVM version (tested on a host other than the build host). It will try to connect to a localhost broker on 61616. Directions: Extract the amq-broker-7.4.0-bin / amq-broker-7.4.1.CR2-bin distribution to a local directory. Create a broker with: [user@node1 bin]$ ./artemis create /home/user/amq/containers/741CR1 Creating ActiveMQ Artemis instance at: /home/user/amq/containers/741CR1 --user: is a mandatory property! Please provide the default username: admin --password: is mandatory with this configuration: Please provide the default password: [admin] --allow-anonymous | --require-login: is a mandatory property! Allow anonymous access?, valid values are Y,N,True,False N Auto tuning journal ... done! Your system can make 2.98 writes per millisecond, your journal-buffer-timeout will be 336000 You can now start the broker by executing: "/home/user/amq/containers/741CR1/bin/artemis" run ... Replace the /home/user/amq/containers/741CR1/etc/broker.xml with the example attached, with configured TEST1 and TEST1.FORWARDED addresses and associated divert Edit jolokia-access.xml / bootstrap.xml as needed if accessing console remotely Extract the camel-springboot-activemq-consumer-1.0-SNAPSHOT.jar.gz archive to the same host as the broker Start the broker with /path/to/broker/bin/artemis run Start the camel application with java -jar camel-springboot-activemq-consumer-1.0-SNAPSHOT.jar and watch for the line that says "connected to remote Broker: amqp://localhost:61616" Open the broker console and find the "TEST.QUEUE.0" address (should be created by the camel application) - the underlying queue should have an attached consumer. Click on the "send" tab to open the send message dialog, select "Plain text" as the message type and enter some text in the text dialog box, then click "Send message" You should see the app pick up the message and drop it into the TEST1 queue and the routed count increment and see the message count increment in the TEST1.FORWARDED queue Now open a separate terminal in the broker bin directory and attempt to browse the TEST1.FORWARDED queue ./artemis browser --user admin --password admin --destination TEST1.FORWARDED --verbose In the client we see: Executing org.apache.activemq.artemis.cli.commands.messages.Browse browser --user admin --password admin --destination TEST1.FORWARDED --verbose Home::/home/user/amq/amq-broker-7.4.1, Instance::/home/user/amq/containers/741CR1 Consumer:: filter = null Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 trying to browse 1000 messages Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 browsed: 0 messages Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 Browser thread finished In the broker log (depending on version), we see: 2019-08-24 11:26:10,775 ERROR [org.apache.activemq.artemis.core.server] AMQ224046: Exception while browser handled from Reference[36]:RELIABLE:AMQPMessage [durable= true , messageID=36, address=TEST1.FORWARDED, size=364, applicationProperties=ApplicationProperties{{breadcrumbId=queue_TEST.QUEUE.0_null, CamelJmsDeliveryMode=2}}, properties=Properties{messageId=ID:88503c13-148d-434b-a2e0-9292a24af2ba:1:1:1-1, userId= null , to= 'TEST1.FORWARDED' , subject= ' null ' , replyTo= ' null ' , correlationId= null , contentType= null , contentEncoding= null , absoluteExpiryTime= null , creationTime=Sat Aug 24 11:01:37 EDT 2019, groupId= ' null ' , groupSequence= null , replyToGroupId= ' null ' }, extraProperties = TypedProperties[_AMQ_AD=TEST1.FORWARDED]]: java.lang.RuntimeException at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:706) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback.sendMessage(CoreSessionCallback.java:123) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1145) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:504) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl$BrowserDeliverer.run(ServerConsumerImpl.java:1461) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_222] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_222] at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] Caused by: java.lang.NullPointerException at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.scanForMessageSection(AMQPMessage.java:357) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.getBody(AMQPMessage.java:319) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:703) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] ... 10 more 2019-08-24 11:26:10,780 WARN [org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage] null : java.lang.NullPointerException at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.scanForMessageSection(AMQPMessage.java:357) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.getBody(AMQPMessage.java:319) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:703) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback.sendMessage(CoreSessionCallback.java:123) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1145) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:504) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl$BrowserDeliverer.run(ServerConsumerImpl.java:1461) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_222] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_222] at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] 2019-08-24 11:26:10,780 ERROR [org.apache.activemq.artemis.core.server] AMQ224046: Exception while browser handled from Reference[45]:RELIABLE:AMQPMessage [durable= true , messageID=45, address=TEST1.FORWARDED, size=358, applicationProperties=ApplicationProperties{{breadcrumbId=queue_TEST.QUEUE.0_null, CamelJmsDeliveryMode=2}}, properties=Properties{messageId=ID:88503c13-148d-434b-a2e0-9292a24af2ba:1:1:2-1, userId= null , to= 'TEST1.FORWARDED' , subject= ' null ' , replyTo= ' null ' , correlationId= null , contentType= null , contentEncoding= null , absoluteExpiryTime= null , creationTime=Sat Aug 24 11:18:53 EDT 2019, groupId= ' null ' , groupSequence= null , replyToGroupId= ' null ' }, extraProperties = TypedProperties[_AMQ_AD=TEST1.FORWARDED]]: java.lang.RuntimeException at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:706) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback.sendMessage(CoreSessionCallback.java:123) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1145) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:504) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl$BrowserDeliverer.run(ServerConsumerImpl.java:1461) [artemis-server-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_222] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_222] at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] Caused by: java.lang.NullPointerException at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.scanForMessageSection(AMQPMessage.java:357) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.getBody(AMQPMessage.java:319) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:703) [artemis-amqp-protocol-2.9.0.redhat-00005.jar:2.9.0.redhat-00005] ... 10 more Now try with --protocol amqp specified: /artemis browser --user admin --password admin --destination TEST1.FORWARDED --verbose --protocol amqp Executing org.apache.activemq.artemis.cli.commands.messages.Browse browser --user admin --password admin --destination TEST1.FORWARDED --verbose --protocol amqp Home::/home/user/amq/amq-broker-7.4.1, Instance::/home/user/amq/containers/741CR1 Consumer:: filter = null 2019-08-24 11:29:36,514 INFO [org.apache.qpid.jms.sasl.SaslMechanismFinder] Best match for SASL auth was: SASL-PLAIN 2019-08-24 11:29:36,563 WARN [org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder] Open of resource:(JmsConnectionInfo { ID:c723999e-9e4c-45ad-99bb-13bd6f441bfb:1, configuredURI = amqp: //localhost:61616, connectedURI = null }) failed: Open failed unexpectedly. 2019-08-24 11:29:36,573 INFO [org.apache.qpid.jms.sasl.SaslMechanismFinder] Best match for SASL auth was: SASL-PLAIN 2019-08-24 11:29:36,600 INFO [org.apache.qpid.jms.JmsConnection] Connection ID:4bc04ad2-4322-4238-8594-1d67e37081b0:2 connected to remote Broker: amqp: //localhost:61616 Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 trying to browse 1000 messages Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 browsing THIS IS A GENERIC TEST MESSAGE ...JmsTextMessage { org.apache.qpid.jms.provider.amqp.message.AmqpJmsTextMessageFacade@585a1911 } Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 browsing SECOND TEST TEXT MESSAGE ...JmsTextMessage { org.apache.qpid.jms.provider.amqp.message.AmqpJmsTextMessageFacade@69003269 } Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 browsed: 2 messages Consumer ActiveMQQueue[TEST1.FORWARDED], thread=0 Browser thread finished I have also attached the camel route code, in case it is needed.

SFDC Cases Counter:
SFDC Cases Open:
SFDC Cases Links:

When trying to browse messages originally delivered by an AMQP client in Hawtio and 500 error is returned with no indication in the log as to what went wrong. When browsing from the CLI with DEBUG logging enabled, the following stack trace is observed:

2019-08-08 10:17:02,465 ERROR [org.apache.activemq.artemis.core.server] AMQ224046: Exception while browser handled from Reference[80208]:RELIABLE:AMQPMessage [durable=true, messageID=80208, address=xxxx.v1.queue, size=1102, applicationProperties=ApplicationProperties{{....}}, properties=Properties{messageId=ID:61d97c33-0ac0-445c-b5a7-440cb6e933a7:1:1:1-1, userId=null, to='xxxx.v1.queue', subject='null', replyTo='null', correlationId=jmsCorrelationId, contentType=null, contentEncoding=null, absoluteExpiryTime=null, creationTime=Thu Aug 08 08:14:58 EDT 2019, groupId='null', groupSequence=null, replyToGroupId='null'}, extraProperties = TypedProperties[_AMQ_AD=xxxx.v1.queue]]: java.lang.RuntimeException
        at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:695) [artemis-amqp-protocol-2.9.0.redhat-00002.jar:2.9.0.redhat-00002]
        at org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback.sendMessage(CoreSessionCallback.java:123) [artemis-server-2.9.0.redhat-00002.jar:2.9.0.redhat-00002]
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1168) [artemis-server-2.9.0.redhat-00002.jar:2.9.0.redhat-00002]
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:510) [artemis-server-2.9.0.redhat-00002.jar:2.9.0.redhat-00002]
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl$BrowserDeliverer.run(ServerConsumerImpl.java:1484) [artemis-server-2.9.0.redhat-00002.jar:2.9.0.redhat-00002]
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.9.0.redhat-00002.jar:2.9.0.redhat-00002]
        at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.9.0.redhat-00002.jar:2.9.0.redhat-00002]
        at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66) [artemis-commons-2.9.0.redhat-00002.jar:2.9.0.redhat-00002]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_181]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_181]
        at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.9.0.redhat-00002.jar:2.9.0.redhat-00002]
Caused by: java.lang.NullPointerException

Selecting protocol "amqp" via the cli browse operation allows the browse operation to complete successfully, but there does not seem to be an option to do this via the web console.

When the broker is restarted, messages are initially browseable via the web console, but after some time the conversion issue is observed.

- - Sort By Name
  - Sort By Date
  - Ascending
  - Descending
  - Thumbnails
  - List
  - Download All

artemis-amqp-protocol-2.9.0.jar
215 kB
2019/11/27 5:37 AM
broker.xml
11 kB
2019/11/27 5:37 AM
camel-springboot-activemq-consumer-1.0-SNAPSHOT.jar.gz
27.31 MB
2019/11/27 5:37 AM
camel-springboot-multicast-artemis.tar.gz
17 kB
2019/11/27 5:37 AM

clones

ENTMQBR-2741 Editing AMQPMessages or Diverts will cause Message Body Loss and its side effects

Closed

duplicates

ENTMQBR-3096 Editing AMQPMessages or Diverts will cause Message Body Loss and its side effects

Closed

is duplicated by

ENTMQBR-2317 With AMQP protocol, messages from custom expiry queue moves to ExpiryQueue after broker restart

Closed

is related to

ENTMQBR-2777 Marking a message as changed during expansion could lead to issues during AMQP to Core Conversion.

Closed

Assignee:: Clebert Suconic

Reporter:: Domenico Francesco Bruscino

Tester:: Roman Vais (Inactive)

Votes:: 0 Vote for this issue

Watchers:: 3 Start watching this issue

Created:: 2019/11/27 5:37 AM

Updated:: 2022/09/09 7:11 AM

Resolved:: 2020/01/10 8:15 AM

Details

Description

Attachments

Attachments

Issue Links

Easy Agile Planning Poker

Activity

People

Dates