This is a bug. The problem is that the broker is using a long value when it should be using an int value instead as defined in the JMS specification. A very similar bug [1] was fixed a while back.
I just opened a new issue for this [2]. I'll send a PR shortly. Thanks for the report! Justin [1] https://issues.apache.org/jira/browse/ARTEMIS-944 [2] https://issues.apache.org/jira/browse/ARTEMIS-3098 On Thu, Feb 4, 2021 at 9:36 AM Florea Cosmin <fosminclo...@gmail.com> wrote: > Hi, > > 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 > > Any ideas on what is happening here? > > > Thank you, > > Cosmin > > >
