[ARTEMIS-3098] OpenWire message conversion fails on JMSXGroupSeq

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Cannot Reproduce
• Affects Version/s: 2.16.0
• Assignee: Justin Bertram
• Reporter: Justin Bertram
• Created: 04/Feb/21 21:15
• Updated: 07/Sep/21 19:58
• Resolved: 07/Sep/21 19:58

Description

Test environment: Linux Fedora 32, OpenJDK Runtime Environment (build 1.8.0_275-b01), activemq-cpp-library-3.9.5, apache-artemis-2.16.0

1) Start Artemis server with default configuration, then run from apache-activemq-5.15.11/bin: "activemq producer", "activemq consumer" ---> all ok, all messages received

2) Start Artemis server with default configuration; using activemq client library send to a queue several messages having JMSXGroupID property set. The broker receives the messages, but the dispatch to the consumer never completes (Wireshark shows that the messages are not sent from the broker). The following exceptions appear in the server's log for each message:

2021-02-04 12:39:43,817 TRACE [org.apache.activemq.artemis.core.server.impl.QueueImpl] Queue R.QA62_ORA12.AuditSequence is delivering reference Reference[884]:RELIABLE:CoreMessage[messageID=884,durable=true,userID=41e334b6-662e-11eb-9a20-0800276be4c9,priority=4, timestamp=Wed Feb 03 16:44:02 EET 2021,expiration=0, durable=true, address=R.QA62_ORA12.AuditSequence,size=15115,properties=TypedProperties[AuditAuthorized=Y,_AMQ_GROUP_ID=000026D5,_AMQ_GROUP_SEQUENCE=0,JMSXGroupID=000026D5,__HDR_BROKER_IN_TIME=1612363442486,AuditId=000026D5,SequenceNumber=0,SourceSysID=,_AMQ_ROUTING_TYPE=1,JMSXGroupSeq=1,__HDR_COMMAND_ID=27,Version=1,__HDR_MESSAGE_ID=[0000 004A 6E00 017B 0100 2349 443A 4665 646F 7261 3330 2D33 3439 3639 2D31  ...  0000 0000 0001 0000 0000 0000 0001 0000 0000 0000 0008 0000 0000 0000 0000),AuditState=DONE,__HDR_DROPPABLE=false,__AMQ_CID=ID:Fedora30-34969-1612363441679-1:0,TranslatorType=Distribution,__HDR_ARRIVAL=0,__HDR_MARSHALL_PROP=[0000 000C 000F 4175 6469 7441 7574 686F 7269 7A65 6409 0001 5900 0741 7564  ...  6E4E 756D 6265 7206 0000 0000 0000 0000 0007 5665 7273 696F 6E05 0000 0001),TransactionNumber=0,__HDR_PRODUCER_ID=[0000 0037 7B01 0023 4944 3A46 6564 6F72 6133 302D 3334 3936 392D 3136 3132 3336 3334 3431 3637 392D 303A 3000 0000 0000 0000 0100 0000 0000 0000 01)]]@1752182275
2021-02-04 12:39:43,817 TRACE [org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl] ServerConsumerImpl::ServerConsumerImpl [id=2, filter=null, binding=LocalQueueBinding [address=R.QA62_ORA12.AuditSequence, queue=QueueImpl[name=R.QA62_ORA12.AuditSequence, postOffice=PostOfficeImpl [server=ActiveMQServerImpl::serverUUID=e773f2c8-6629-11eb-a149-0800276be4c9], temp=false]@45d2ade3, filter=null, name=R.QA62_ORA12.AuditSequence, clusterName=R.QA62_ORA12.AuditSequencee773f2c8-6629-11eb-a149-0800276be4c9]] Handling reference Reference[884]:RELIABLE:CoreMessage[messageID=884,durable=true,userID=41e334b6-662e-11eb-9a20-0800276be4c9,priority=4, timestamp=Wed Feb 03 16:44:02 EET 2021,expiration=0, durable=true, address=R.QA62_ORA12.AuditSequence,size=15115,properties=TypedProperties[AuditAuthorized=Y,_AMQ_GROUP_ID=000026D5,_AMQ_GROUP_SEQUENCE=0,JMSXGroupID=000026D5,__HDR_BROKER_IN_TIME=1612363442486,AuditId=000026D5,SequenceNumber=0,SourceSysID=,_AMQ_ROUTING_TYPE=1,JMSXGroupSeq=1,__HDR_COMMAND_ID=27,Version=1,__HDR_MESSAGE_ID=[0000 004A 6E00 017B 0100 2349 443A 4665 646F 7261 3330 2D33 3439 3639 2D31  ...  0000 0000 0001 0000 0000 0000 0001 0000 0000 0000 0008 0000 0000 0000 0000),AuditState=DONE,__HDR_DROPPABLE=false,__AMQ_CID=ID:Fedora30-34969-1612363441679-1:0,TranslatorType=Distribution,__HDR_ARRIVAL=0,__HDR_MARSHALL_PROP=[0000 000C 000F 4175 6469 7441 7574 686F 7269 7A65 6409 0001 5900 0741 7564  ...  6E4E 756D 6265 7206 0000 0000 0000 0000 0007 5665 7273 696F 6E05 0000 0001),TransactionNumber=0,__HDR_PRODUCER_ID=[0000 0037 7B01 0023 4944 3A46 6564 6F72 6133 302D 3334 3936 392D 3136 3132 3336 3334 3431 3637 392D 303A 3000 0000 0000 0000 0100 0000 0000 0000 01)]]@1752182275
2021-02-04 12:39:43,817 DEBUG [org.apache.activemq.artemis.core.server.impl.QueueMessageMetrics] QueuePendingMessageMetrics[queue=R.QA62_ORA12.AuditSequence, name=delivering] increment messageCount to 8: Reference[884]:RELIABLE:CoreMessage[messageID=884,durable=true,userID=41e334b6-662e-11eb-9a20-0800276be4c9,priority=4, timestamp=Wed Feb 03 16:44:02 EET 2021,expiration=0, durable=true, address=R.QA62_ORA12.AuditSequence,size=15115,properties=TypedProperties[AuditAuthorized=Y,_AMQ_GROUP_ID=000026D5,_AMQ_GROUP_SEQUENCE=0,JMSXGroupID=000026D5,__HDR_BROKER_IN_TIME=1612363442486,AuditId=000026D5,SequenceNumber=0,SourceSysID=,_AMQ_ROUTING_TYPE=1,JMSXGroupSeq=1,__HDR_COMMAND_ID=27,Version=1,__HDR_MESSAGE_ID=[0000 004A 6E00 017B 0100 2349 443A 4665 646F 7261 3330 2D33 3439 3639 2D31  ...  0000 0000 0001 0000 0000 0000 0001 0000 0000 0000 0008 0000 0000 0000 0000),AuditState=DONE,__HDR_DROPPABLE=false,__AMQ_CID=ID:Fedora30-34969-1612363441679-1:0,TranslatorType=Distribution,__HDR_ARRIVAL=0,__HDR_MARSHALL_PROP=[0000 000C 000F 4175 6469 7441 7574 686F 7269 7A65 6409 0001 5900 0741 7564  ...  6E4E 756D 6265 7206 0000 0000 0000 0000 0007 5665 7273 696F 6E05 0000 0001),TransactionNumber=0,__HDR_PRODUCER_ID=[0000 0037 7B01 0023 4944 3A46 6564 6F72 6133 302D 3334 3936 392D 3136 3132 3336 3334 3431 3637 392D 303A 3000 0000 0000 0000 0100 0000 0000 0000 01)]]@1752182275
2021-02-04 12:39:43,817 DEBUG [org.apache.activemq.artemis.core.server.impl.QueueMessageMetrics] QueuePendingMessageMetrics[queue=R.QA62_ORA12.AuditSequence, name=pending] decrement messageCount to 204: Reference[884]:RELIABLE:CoreMessage[messageID=884,durable=true,userID=41e334b6-662e-11eb-9a20-0800276be4c9,priority=4, timestamp=Wed Feb 03 16:44:02 EET 2021,expiration=0, durable=true, address=R.QA62_ORA12.AuditSequence,size=15115,properties=TypedProperties[AuditAuthorized=Y,_AMQ_GROUP_ID=000026D5,_AMQ_GROUP_SEQUENCE=0,JMSXGroupID=000026D5,__HDR_BROKER_IN_TIME=1612363442486,AuditId=000026D5,SequenceNumber=0,SourceSysID=,_AMQ_ROUTING_TYPE=1,JMSXGroupSeq=1,__HDR_COMMAND_ID=27,Version=1,__HDR_MESSAGE_ID=[0000 004A 6E00 017B 0100 2349 443A 4665 646F 7261 3330 2D33 3439 3639 2D31  ...  0000 0000 0001 0000 0000 0000 0001 0000 0000 0000 0008 0000 0000 0000 0000),AuditState=DONE,__HDR_DROPPABLE=false,__AMQ_CID=ID:Fedora30-34969-1612363441679-1:0,TranslatorType=Distribution,__HDR_ARRIVAL=0,__HDR_MARSHALL_PROP=[0000 000C 000F 4175 6469 7441 7574 686F 7269 7A65 6409 0001 5900 0741 7564  ...  6E4E 756D 6265 7206 0000 0000 0000 0000 0007 5665 7273 696F 6E05 0000 0001),TransactionNumber=0,__HDR_PRODUCER_ID=[0000 0037 7B01 0023 4944 3A46 6564 6F72 6133 302D 3334 3936 392D 3136 3132 3336 3334 3431 3637 392D 303A 3000 0000 0000 0000 0100 0000 0000 0000 01)]]@1752182275
2021-02-04 12:39:43,820 WARN [org.apache.activemq.artemis.core.server] Error during message dispatch: java.io.IOException: exception setting property JMSXGroupSeq : 1
     at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.setAMQMsgObjectProperties(OpenWireMessageConverter.java:968) [artemis-openwire-protocol-2.16.0.jar:2.16.0]
     at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:697) [artemis-openwire-protocol-2.16.0.jar:2.16.0]
     at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:502) [artemis-openwire-protocol-2.16.0.jar:2.16.0]
     at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:268) [artemis-openwire-protocol-2.16.0.jar:2.16.0]
     at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:309) [artemis-openwire-protocol-2.16.0.jar:2.16.0]
     at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1168) [artemis-server-2.16.0.jar:2.16.0]
     at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:507) [artemis-server-2.16.0.jar:2.16.0]
     at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:3744) [artemis-server-2.16.0.jar:2.16.0]
     at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:3048) [artemis-server-2.16.0.jar:2.16.0]
     at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$2400(QueueImpl.java:125) [artemis-server-2.16.0.jar:2.16.0]
     at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:4119) [artemis-server-2.16.0.jar:2.16.0]
     at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.16.0.jar:2.16.0]
     at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.16.0.jar:2.16.0]
     at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:65) [artemis-commons-2.16.0.jar:2.16.0]
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_275]
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_275]
     at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.16.0.jar:2.16.0]
Caused by: javax.jms.MessageFormatException: Property JMSXGroupSeq cannot be set from a java.lang.Long.
     at org.apache.activemq.command.ActiveMQMessage$3.set(ActiveMQMessage.java:381) [activemq-client-5.14.5.jar:5.14.5]
     at org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:509) [activemq-client-5.14.5.jar:5.14.5]
     at org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:488) [activemq-client-5.14.5.jar:5.14.5]
     at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.setAMQMsgObjectProperties(OpenWireMessageConverter.java:964) [artemis-openwire-protocol-2.16.0.jar:2.16.0]
     ... 16 more

Issue Links

• relates to: ARTEMIS-944 Broker can't convert AMQP python message to Openwire format