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

[AMQP] On transacted session.commit() of receiver client, messages are read, but queue is not cleared out

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Critical Critical
    • A-MQ 7.0.0.GA
    • A-MQ 7.0.0.ER8
    • None
    • Hide

      Transacted scenario

      [1,root@r7x0_mtoth clients]$ java -jar /var/dtests/node_data/clients/amqx.jar queue -a add -n lal
Queue 'lal' created

      Send few messages in

      [0,root@r7x0_mtoth clients]$ ./aac1_sender.java.sh --timeout 10 --log-msgs dict  --conn-username admin --conn-password admin --address lal --count 5 --tx-size 5 --tx-action commit
12:06:13,375 DEBUG Connection='amqp://localhost:5672?jms.username=admin&jms.password=admin'
12:06:14,031 INFO Best match for SASL auth was: SASL-PLAIN
12:06:14,069 DEBUG AmqpConnection { ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1 } is now open: 
12:06:14,070 INFO Connection ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1 connected to remote Broker: amqp://localhost:5672
12:06:14,132 DEBUG New TX started: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1
12:06:14,132 DEBUG Begin: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1
12:06:14,138 DEBUG Creating AmqpFixedProducer for: lal
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974167, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974197, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974201, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974203, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974206, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
12:06:14,209 DEBUG Commit: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1 syncCount: 0
12:06:14,371 DEBUG Last TX request succeeded: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1
12:06:14,379 DEBUG New TX started: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:2
12:06:14,379 DEBUG Begin: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:2
12:06:14,379 DEBUG Performed Commit TX action
12:06:14,379 DEBUG Performed None TX action
12:06:14,380 DEBUG Rollback: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:2 syncCount: 0
12:06:14,427 DEBUG Last TX request succeeded: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:2
12:06:14,437 DEBUG AmqpSession { ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1 } is now closed: 
12:06:14,443 DEBUG AmqpConnection { ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1 } is now closed: 
12:06:14,447 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@37e547da[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is shutdown: true and terminated: true took: 0.000 seconds.

      Check queue stats (focus on "numberOfMessages" property)

      [0,root@r7x0_mtoth clients]$ java -jar /var/dtests/node_data/clients/amqx.jar queue -a properties -n lal
{'temporary': False, 'numberOfBytesPerPage': 10485760, 'paused': False, 'messageCount': 5, 'rolesAsJSON': [{'createNonDurableQueue': True, 'consume': True, 'send': True, 'deleteNonDurableQueue': True, 'createDurableQueue': True, 'name': 'amq', 'manage': True, 'deleteDurableQueue': True}], 'messagesAcknowledged': 0, 'deadLetterAddress': 'jms.queue.DLQ', 'durable': False, 'numberOfPages': 0, 'deliveringCount': 0, 'numberOfMessages': 5, 'expiryAddress': 'jms.queue.ExpiryQueue', 'bindingNames': ['lal'], 'messagesAdded': 5, 'address': 'lal', 'consumerCount': 0, 'queueNames': ['lal'], 'scheduledCount': 0, 'paging': False, 'filter': None, 'addressSize': 6550, 'firstMessageTimestamp': 1469181974167, 'name': 'lal', 'iD': 16014, 'firstMessageAge': 10746}

      Receive all messages and commit session at the end

      [0,root@r7x0_mtoth clients]$ ./aac1_receiver.java.sh --timeout 10 --log-msgs dict  --conn-username admin --conn-password admin --address lal --count 5 --tx-size 5 --tx-action commit
12:06:51,364 DEBUG Using destination type:javax.jms.Queue
12:06:51,411 DEBUG Connection='amqp://localhost:5672?jms.username=admin&jms.password=admin'
12:06:52,131 INFO Best match for SASL auth was: SASL-PLAIN
12:06:52,171 DEBUG AmqpConnection { ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1 } is now open: 
12:06:52,173 INFO Connection ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1 connected to remote Broker: amqp://localhost:5672
12:06:52,229 DEBUG New TX started: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1
12:06:52,229 DEBUG Begin: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1
12:06:52,310 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 1, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1}
12:06:52,312 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 2, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1}
12:06:52,312 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 3, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1}
12:06:52,313 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 4, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1}
12:06:52,313 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 5, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1}
12:06:52,314 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 1, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974167, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1'}, 'content': None}
12:06:52,333 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 2, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974197, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2'}, 'content': None}
12:06:52,335 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 3, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974201, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3'}, 'content': None}
12:06:52,336 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 4, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974203, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4'}, 'content': None}
12:06:52,338 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 5, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974206, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5'}, 'content': None}
12:06:52,339 DEBUG Commit: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1 syncCount: 0
12:06:52,364 DEBUG Last TX request succeeded: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1
12:06:52,370 DEBUG New TX started: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:2
12:06:52,370 DEBUG Begin: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:2
12:06:52,370 DEBUG Performed Commit TX action
12:06:52,379 DEBUG AmqpConsumer { ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1 } is now closed: 
12:06:52,380 DEBUG Performed None TX action
12:06:52,380 DEBUG Rollback: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:2 syncCount: 0
12:06:52,388 DEBUG Last TX request succeeded: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:2
12:06:52,392 DEBUG AmqpSession { ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1 } is now closed: 
12:06:52,396 DEBUG AmqpConnection { ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1 } is now closed: 
12:06:52,399 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@3c153a1[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is shutdown: true and terminated: true took: 0.000 seconds.

      Check queue stats again (numberOfMessages)

      [0,root@r7x0_mtoth clients]$ java -jar /var/dtests/node_data/clients/amqx.jar queue -a properties -n lal
{'temporary': False, 'numberOfBytesPerPage': 10485760, 'paused': False, 'messageCount': 5, 'rolesAsJSON': [{'createNonDurableQueue': True, 'consume': True, 'send': True, 'deleteNonDurableQueue': True, 'createDurableQueue': True, 'name': 'amq', 'manage': True, 'deleteDurableQueue': True}], 'messagesAcknowledged': 0, 'deadLetterAddress': 'jms.queue.DLQ', 'durable': False, 'numberOfPages': 0, 'deliveringCount': 0, 'numberOfMessages': 5, 'expiryAddress': 'jms.queue.ExpiryQueue', 'bindingNames': ['lal'], 'messagesAdded': 5, 'address': 'lal', 'consumerCount': 0, 'queueNames': ['lal'], 'scheduledCount': 0, 'paging': False, 'filter': None, 'addressSize': 6550, 'firstMessageTimestamp': 1469181974167, 'name': 'lal', 'iD': 16014, 'firstMessageAge': 43957}

      You can receive them again

      [0,root@r7x0_mtoth clients]$ ./aac1_receiver.java.sh --timeout 10 --log-msgs dict  --conn-username admin --conn-password admin --address lal --count 5 --tx-size 5 --tx-action commit
12:07:09,218 DEBUG Using destination type:javax.jms.Queue
12:07:09,262 DEBUG Connection='amqp://localhost:5672?jms.username=admin&jms.password=admin'
12:07:09,951 INFO Best match for SASL auth was: SASL-PLAIN
12:07:09,998 DEBUG AmqpConnection { ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1 } is now open: 
12:07:10,000 INFO Connection ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1 connected to remote Broker: amqp://localhost:5672
12:07:10,063 DEBUG New TX started: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1
12:07:10,063 DEBUG Begin: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1
12:07:10,115 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 1, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1}
12:07:10,116 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 2, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1}
12:07:10,117 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 3, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1}
12:07:10,117 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 4, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1}
12:07:10,118 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 5, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1}
12:07:10,118 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 1, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974167, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1'}, 'content': None}
12:07:10,137 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 2, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974197, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2'}, 'content': None}
12:07:10,140 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 3, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974201, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3'}, 'content': None}
12:07:10,142 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 4, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974203, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4'}, 'content': None}
12:07:10,143 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 5, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469181974206, 'address': 'lal', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5'}, 'content': None}
12:07:10,144 DEBUG Commit: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1 syncCount: 0
12:07:10,152 DEBUG Last TX request succeeded: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1
12:07:10,160 DEBUG New TX started: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:2
12:07:10,161 DEBUG Begin: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:2
12:07:10,161 DEBUG Performed Commit TX action
12:07:10,169 DEBUG AmqpConsumer { ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1 } is now closed: 
12:07:10,170 DEBUG Performed None TX action
12:07:10,170 DEBUG Rollback: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:2 syncCount: 0
12:07:10,181 DEBUG Last TX request succeeded: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:2
12:07:10,186 DEBUG AmqpSession { ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1 } is now closed: 
12:07:10,192 DEBUG AmqpConnection { ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1 } is now closed: 
12:07:10,196 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@3c153a1[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is shutdown: true and terminated: true took: 0.000 seconds.

      Not transacted receiver example does what is expected. Send some messages to the queue.

      Use new  queue "lala"
[0,root@r7x0_mtoth clients]$ ./aac1_sender.java.sh --timeout 10 --log-msgs dict  --conn-username admin --conn-password admin --address lala --count 5 --tx-size 5 --tx-action commit
12:08:35,963 DEBUG Connection='amqp://localhost:5672?jms.username=admin&jms.password=admin'
12:08:36,719 INFO Best match for SASL auth was: SASL-PLAIN
12:08:36,753 DEBUG AmqpConnection { ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1 } is now open: 
12:08:36,754 INFO Connection ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1 connected to remote Broker: amqp://localhost:5672
12:08:36,812 DEBUG New TX started: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1
12:08:36,813 DEBUG Begin: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1
12:08:36,818 DEBUG Creating AmqpFixedProducer for: lala
{'redelivered': False, 'reply_to': None, 'id': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-1', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469182116837, 'address': 'lala', 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'redelivered': False, 'reply_to': None, 'id': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-2', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469182116863, 'address': 'lala', 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'redelivered': False, 'reply_to': None, 'id': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-3', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469182116864, 'address': 'lala', 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'redelivered': False, 'reply_to': None, 'id': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-4', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469182116866, 'address': 'lala', 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
{'redelivered': False, 'reply_to': None, 'id': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-5', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469182116869, 'address': 'lala', 'properties': {'JMSXDeliveryCount': 1}, 'content': None}
12:08:36,872 DEBUG Commit: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1 syncCount: 0
12:08:36,889 DEBUG Last TX request succeeded: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1
12:08:36,894 DEBUG New TX started: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:2
12:08:36,894 DEBUG Begin: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:2
12:08:36,895 DEBUG Performed Commit TX action
12:08:36,895 DEBUG Performed None TX action
12:08:36,895 DEBUG Rollback: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:2 syncCount: 0
12:08:36,902 DEBUG Last TX request succeeded: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:2
12:08:36,908 DEBUG AmqpSession { ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1 } is now closed: 
12:08:36,911 DEBUG AmqpConnection { ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1 } is now closed: 
12:08:36,917 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@37e547da[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is shutdown: true and terminated: true took: 0.000 seconds.

      Check queue

      [0,root@r7x0_mtoth clients]$ java -jar /var/dtests/node_data/clients/amqx.jar queue -a properties -n lala
{'temporary': False, 'numberOfBytesPerPage': 10485760, 'paused': False, 'messageCount': 5, 'rolesAsJSON': [{'createNonDurableQueue': True, 'consume': True, 'send': True, 'deleteNonDurableQueue': True, 'createDurableQueue': True, 'name': 'amq', 'manage': True, 'deleteDurableQueue': True}], 'messagesAcknowledged': 0, 'deadLetterAddress': 'jms.queue.DLQ', 'durable': False, 'numberOfPages': 0, 'deliveringCount': 0, 'numberOfMessages': 5, 'expiryAddress': 'jms.queue.ExpiryQueue', 'bindingNames': ['lala'], 'messagesAdded': 5, 'address': 'lala', 'consumerCount': 0, 'queueNames': ['lala'], 'scheduledCount': 0, 'paging': False, 'filter': None, 'addressSize': 6550, 'firstMessageTimestamp': 1469182116837, 'name': 'lala', 'iD': 16009, 'firstMessageAge': 5723}

      Receive messages

      [0,root@r7x0_mtoth clients]$ ./aac1_receiver.java.sh --timeout 10 --log-msgs dict  --conn-username admin --conn-password admin --address lala --count 5 
12:08:55,464 DEBUG Using destination type:javax.jms.Queue
12:08:55,510 DEBUG Connection='amqp://localhost:5672?jms.username=admin&jms.password=admin'
12:08:56,237 INFO Best match for SASL auth was: SASL-PLAIN
12:08:56,272 DEBUG AmqpConnection { ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1 } is now open: 
12:08:56,274 INFO Connection ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1 connected to remote Broker: amqp://localhost:5672
12:08:56,376 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 1, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-1, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1}
12:08:56,377 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 2, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-2, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1}
12:08:56,378 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 3, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-3, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1}
12:08:56,378 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 4, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-4, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1}
12:08:56,379 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 5, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-5, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1}
12:08:56,383 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 1, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-1, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-1', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469182116837, 'address': 'lala', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-1'}, 'content': None}
12:08:56,406 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 2, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-2, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-2', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469182116863, 'address': 'lala', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-2'}, 'content': None}
12:08:56,411 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 3, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-3, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-3', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469182116864, 'address': 'lala', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-3'}, 'content': None}
12:08:56,414 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 4, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-4, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-4', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469182116866, 'address': 'lala', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-4'}, 'content': None}
12:08:56,417 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 5, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-5, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1}
{'redelivered': False, 'reply_to': None, 'id': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-5', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1469182116869, 'address': 'lala', 'properties': {'JMSXDeliveryCount': 1, 'NATIVE_MESSAGE_ID': ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-5'}, 'content': None}
12:08:56,428 DEBUG AmqpConsumer { ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1 } is now closed: 
12:08:56,433 DEBUG AmqpSession { ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1 } is now closed: 
12:08:56,437 DEBUG AmqpConnection { ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1 } is now closed: 
12:08:56,441 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@258e2e41[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is shutdown: true and terminated: true took: 0.000 seconds.

      Correct numberOfMessages = 0

      [0,root@r7x0_mtoth clients]$ java -jar /var/dtests/node_data/clients/amqx.jar queue -a properties -n lala
{'temporary': False, 'numberOfBytesPerPage': 10485760, 'paused': False, 'messageCount': 0, 'rolesAsJSON': [{'createNonDurableQueue': True, 'consume': True, 'send': True, 'deleteNonDurableQueue': True, 'createDurableQueue': True, 'name': 'amq', 'manage': True, 'deleteDurableQueue': True}], 'messagesAcknowledged': 5, 'deadLetterAddress': 'jms.queue.DLQ', 'durable': False, 'numberOfPages': 0, 'deliveringCount': 0, 'numberOfMessages': 0, 'expiryAddress': 'jms.queue.ExpiryQueue', 'bindingNames': ['lala'], 'messagesAdded': 5, 'address': 'lala', 'consumerCount': 0, 'queueNames': ['lala'], 'scheduledCount': 0, 'paging': False, 'filter': None, 'addressSize': 0, 'firstMessageTimestamp': None, 'name': 'lala', 'iD': 16009, 'firstMessageAge': None}
      Show
      Transacted scenario [1,root@r7x0_mtoth clients]$ java -jar / var /dtests/node_data/clients/amqx.jar queue -a add -n lal Queue 'lal' created Send few messages in [0,root@r7x0_mtoth clients]$ ./aac1_sender.java.sh --timeout 10 --log-msgs dict --conn-username admin --conn-password admin --address lal --count 5 --tx-size 5 --tx-action commit 12:06:13,375 DEBUG Connection= 'amqp: //localhost:5672?jms.username=admin&jms.password=admin' 12:06:14,031 INFO Best match for SASL auth was: SASL-PLAIN 12:06:14,069 DEBUG AmqpConnection { ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1 } is now open: 12:06:14,070 INFO Connection ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1 connected to remote Broker: amqp: //localhost:5672 12:06:14,132 DEBUG New TX started: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1 12:06:14,132 DEBUG Begin: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1 12:06:14,138 DEBUG Creating AmqpFixedProducer for : lal { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974167, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1}, 'content' : None} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974197, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1}, 'content' : None} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974201, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1}, 'content' : None} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974203, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1}, 'content' : None} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974206, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1}, 'content' : None} 12:06:14,209 DEBUG Commit: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1 syncCount: 0 12:06:14,371 DEBUG Last TX request succeeded: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1 12:06:14,379 DEBUG New TX started: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:2 12:06:14,379 DEBUG Begin: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:2 12:06:14,379 DEBUG Performed Commit TX action 12:06:14,379 DEBUG Performed None TX action 12:06:14,380 DEBUG Rollback: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:2 syncCount: 0 12:06:14,427 DEBUG Last TX request succeeded: TX:ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:2 12:06:14,437 DEBUG AmqpSession { ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1 } is now closed: 12:06:14,443 DEBUG AmqpConnection { ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1 } is now closed: 12:06:14,447 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@37e547da[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is shutdown: true and terminated: true took: 0.000 seconds. Check queue stats (focus on "numberOfMessages" property) [0,root@r7x0_mtoth clients]$ java -jar / var /dtests/node_data/clients/amqx.jar queue -a properties -n lal { 'temporary' : False, 'numberOfBytesPerPage' : 10485760, 'paused' : False, 'messageCount' : 5, 'rolesAsJSON' : [{ 'createNonDurableQueue' : True, 'consume' : True, 'send' : True, 'deleteNonDurableQueue' : True, 'createDurableQueue' : True, 'name' : 'amq' , 'manage' : True, 'deleteDurableQueue' : True}], 'messagesAcknowledged' : 0, 'deadLetterAddress' : 'jms.queue.DLQ' , 'durable' : False, 'numberOfPages' : 0, 'deliveringCount' : 0, 'numberOfMessages' : 5, 'expiryAddress' : 'jms.queue.ExpiryQueue' , 'bindingNames' : [ 'lal' ], 'messagesAdded' : 5, 'address' : 'lal' , 'consumerCount' : 0, 'queueNames' : [ 'lal' ], 'scheduledCount' : 0, 'paging' : False, 'filter' : None, 'addressSize' : 6550, 'firstMessageTimestamp' : 1469181974167, 'name' : 'lal' , 'iD' : 16014, 'firstMessageAge' : 10746} Receive all messages and commit session at the end [0,root@r7x0_mtoth clients]$ ./aac1_receiver.java.sh --timeout 10 --log-msgs dict --conn-username admin --conn-password admin --address lal --count 5 --tx-size 5 --tx-action commit 12:06:51,364 DEBUG Using destination type:javax.jms.Queue 12:06:51,411 DEBUG Connection= 'amqp: //localhost:5672?jms.username=admin&jms.password=admin' 12:06:52,131 INFO Best match for SASL auth was: SASL-PLAIN 12:06:52,171 DEBUG AmqpConnection { ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1 } is now open: 12:06:52,173 INFO Connection ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1 connected to remote Broker: amqp: //localhost:5672 12:06:52,229 DEBUG New TX started: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1 12:06:52,229 DEBUG Begin: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1 12:06:52,310 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 1, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1} 12:06:52,312 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 2, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1} 12:06:52,312 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 3, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1} 12:06:52,313 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 4, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1} 12:06:52,313 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 5, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1} 12:06:52,314 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 1, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974167, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1' }, 'content' : None} 12:06:52,333 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 2, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974197, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2' }, 'content' : None} 12:06:52,335 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 3, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974201, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3' }, 'content' : None} 12:06:52,336 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 4, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974203, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4' }, 'content' : None} 12:06:52,338 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 5, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5, consumerId = ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974206, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5' }, 'content' : None} 12:06:52,339 DEBUG Commit: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1 syncCount: 0 12:06:52,364 DEBUG Last TX request succeeded: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1 12:06:52,370 DEBUG New TX started: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:2 12:06:52,370 DEBUG Begin: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:2 12:06:52,370 DEBUG Performed Commit TX action 12:06:52,379 DEBUG AmqpConsumer { ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1:1 } is now closed: 12:06:52,380 DEBUG Performed None TX action 12:06:52,380 DEBUG Rollback: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:2 syncCount: 0 12:06:52,388 DEBUG Last TX request succeeded: TX:ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:2 12:06:52,392 DEBUG AmqpSession { ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1:1 } is now closed: 12:06:52,396 DEBUG AmqpConnection { ID::bf836736-82e6-4547-b48f-60c3fa79d1ff:1 } is now closed: 12:06:52,399 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@3c153a1[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is shutdown: true and terminated: true took: 0.000 seconds. Check queue stats again (numberOfMessages) [0,root@r7x0_mtoth clients]$ java -jar / var /dtests/node_data/clients/amqx.jar queue -a properties -n lal { 'temporary' : False, 'numberOfBytesPerPage' : 10485760, 'paused' : False, 'messageCount' : 5, 'rolesAsJSON' : [{ 'createNonDurableQueue' : True, 'consume' : True, 'send' : True, 'deleteNonDurableQueue' : True, 'createDurableQueue' : True, 'name' : 'amq' , 'manage' : True, 'deleteDurableQueue' : True}], 'messagesAcknowledged' : 0, 'deadLetterAddress' : 'jms.queue.DLQ' , 'durable' : False, 'numberOfPages' : 0, 'deliveringCount' : 0, 'numberOfMessages' : 5, 'expiryAddress' : 'jms.queue.ExpiryQueue' , 'bindingNames' : [ 'lal' ], 'messagesAdded' : 5, 'address' : 'lal' , 'consumerCount' : 0, 'queueNames' : [ 'lal' ], 'scheduledCount' : 0, 'paging' : False, 'filter' : None, 'addressSize' : 6550, 'firstMessageTimestamp' : 1469181974167, 'name' : 'lal' , 'iD' : 16014, 'firstMessageAge' : 43957} You can receive them again [0,root@r7x0_mtoth clients]$ ./aac1_receiver.java.sh --timeout 10 --log-msgs dict --conn-username admin --conn-password admin --address lal --count 5 --tx-size 5 --tx-action commit 12:07:09,218 DEBUG Using destination type:javax.jms.Queue 12:07:09,262 DEBUG Connection= 'amqp: //localhost:5672?jms.username=admin&jms.password=admin' 12:07:09,951 INFO Best match for SASL auth was: SASL-PLAIN 12:07:09,998 DEBUG AmqpConnection { ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1 } is now open: 12:07:10,000 INFO Connection ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1 connected to remote Broker: amqp: //localhost:5672 12:07:10,063 DEBUG New TX started: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1 12:07:10,063 DEBUG Begin: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1 12:07:10,115 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 1, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1} 12:07:10,116 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 2, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1} 12:07:10,117 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 3, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1} 12:07:10,117 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 4, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1} 12:07:10,118 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 5, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1} 12:07:10,118 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 1, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974167, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-1' }, 'content' : None} 12:07:10,137 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 2, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974197, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-2' }, 'content' : None} 12:07:10,140 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 3, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974201, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-3' }, 'content' : None} 12:07:10,142 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 4, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974203, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-4' }, 'content' : None} 12:07:10,143 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 5, messageId = ID::3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5, consumerId = ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469181974206, 'address' : 'lal' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':3d498516-f862-4e99-a1e0-25a2d5d19ec6:1:1:1-5' }, 'content' : None} 12:07:10,144 DEBUG Commit: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1 syncCount: 0 12:07:10,152 DEBUG Last TX request succeeded: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1 12:07:10,160 DEBUG New TX started: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:2 12:07:10,161 DEBUG Begin: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:2 12:07:10,161 DEBUG Performed Commit TX action 12:07:10,169 DEBUG AmqpConsumer { ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1:1 } is now closed: 12:07:10,170 DEBUG Performed None TX action 12:07:10,170 DEBUG Rollback: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:2 syncCount: 0 12:07:10,181 DEBUG Last TX request succeeded: TX:ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:2 12:07:10,186 DEBUG AmqpSession { ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1:1 } is now closed: 12:07:10,192 DEBUG AmqpConnection { ID::8983571e-a8ea-4b48-8d00-7cf29e3c350c:1 } is now closed: 12:07:10,196 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@3c153a1[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is shutdown: true and terminated: true took: 0.000 seconds. Not transacted receiver example does what is expected. Send some messages to the queue. Use new queue "lala" [0,root@r7x0_mtoth clients]$ ./aac1_sender.java.sh --timeout 10 --log-msgs dict --conn-username admin --conn-password admin --address lala --count 5 --tx-size 5 --tx-action commit 12:08:35,963 DEBUG Connection= 'amqp: //localhost:5672?jms.username=admin&jms.password=admin' 12:08:36,719 INFO Best match for SASL auth was: SASL-PLAIN 12:08:36,753 DEBUG AmqpConnection { ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1 } is now open: 12:08:36,754 INFO Connection ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1 connected to remote Broker: amqp: //localhost:5672 12:08:36,812 DEBUG New TX started: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1 12:08:36,813 DEBUG Begin: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1 12:08:36,818 DEBUG Creating AmqpFixedProducer for : lala { 'redelivered' : False, 'reply_to' : None, 'id' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-1' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469182116837, 'address' : 'lala' , 'properties' : { 'JMSXDeliveryCount' : 1}, 'content' : None} { 'redelivered' : False, 'reply_to' : None, 'id' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-2' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469182116863, 'address' : 'lala' , 'properties' : { 'JMSXDeliveryCount' : 1}, 'content' : None} { 'redelivered' : False, 'reply_to' : None, 'id' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-3' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469182116864, 'address' : 'lala' , 'properties' : { 'JMSXDeliveryCount' : 1}, 'content' : None} { 'redelivered' : False, 'reply_to' : None, 'id' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-4' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469182116866, 'address' : 'lala' , 'properties' : { 'JMSXDeliveryCount' : 1}, 'content' : None} { 'redelivered' : False, 'reply_to' : None, 'id' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-5' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469182116869, 'address' : 'lala' , 'properties' : { 'JMSXDeliveryCount' : 1}, 'content' : None} 12:08:36,872 DEBUG Commit: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1 syncCount: 0 12:08:36,889 DEBUG Last TX request succeeded: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1 12:08:36,894 DEBUG New TX started: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:2 12:08:36,894 DEBUG Begin: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:2 12:08:36,895 DEBUG Performed Commit TX action 12:08:36,895 DEBUG Performed None TX action 12:08:36,895 DEBUG Rollback: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:2 syncCount: 0 12:08:36,902 DEBUG Last TX request succeeded: TX:ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:2 12:08:36,908 DEBUG AmqpSession { ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1 } is now closed: 12:08:36,911 DEBUG AmqpConnection { ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1 } is now closed: 12:08:36,917 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@37e547da[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is shutdown: true and terminated: true took: 0.000 seconds. Check queue [0,root@r7x0_mtoth clients]$ java -jar / var /dtests/node_data/clients/amqx.jar queue -a properties -n lala { 'temporary' : False, 'numberOfBytesPerPage' : 10485760, 'paused' : False, 'messageCount' : 5, 'rolesAsJSON' : [{ 'createNonDurableQueue' : True, 'consume' : True, 'send' : True, 'deleteNonDurableQueue' : True, 'createDurableQueue' : True, 'name' : 'amq' , 'manage' : True, 'deleteDurableQueue' : True}], 'messagesAcknowledged' : 0, 'deadLetterAddress' : 'jms.queue.DLQ' , 'durable' : False, 'numberOfPages' : 0, 'deliveringCount' : 0, 'numberOfMessages' : 5, 'expiryAddress' : 'jms.queue.ExpiryQueue' , 'bindingNames' : [ 'lala' ], 'messagesAdded' : 5, 'address' : 'lala' , 'consumerCount' : 0, 'queueNames' : [ 'lala' ], 'scheduledCount' : 0, 'paging' : False, 'filter' : None, 'addressSize' : 6550, 'firstMessageTimestamp' : 1469182116837, 'name' : 'lala' , 'iD' : 16009, 'firstMessageAge' : 5723} Receive messages [0,root@r7x0_mtoth clients]$ ./aac1_receiver.java.sh --timeout 10 --log-msgs dict --conn-username admin --conn-password admin --address lala --count 5 12:08:55,464 DEBUG Using destination type:javax.jms.Queue 12:08:55,510 DEBUG Connection= 'amqp: //localhost:5672?jms.username=admin&jms.password=admin' 12:08:56,237 INFO Best match for SASL auth was: SASL-PLAIN 12:08:56,272 DEBUG AmqpConnection { ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1 } is now open: 12:08:56,274 INFO Connection ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1 connected to remote Broker: amqp: //localhost:5672 12:08:56,376 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 1, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-1, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1} 12:08:56,377 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 2, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-2, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1} 12:08:56,378 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 3, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-3, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1} 12:08:56,378 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 4, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-4, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1} 12:08:56,379 DEBUG Dispatching received message: JmsInboundMessageDispatch {sequence = 5, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-5, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1} 12:08:56,383 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 1, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-1, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-1' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469182116837, 'address' : 'lala' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-1' }, 'content' : None} 12:08:56,406 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 2, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-2, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-2' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469182116863, 'address' : 'lala' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-2' }, 'content' : None} 12:08:56,411 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 3, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-3, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-3' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469182116864, 'address' : 'lala' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-3' }, 'content' : None} 12:08:56,414 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 4, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-4, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-4' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469182116866, 'address' : 'lala' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-4' }, 'content' : None} 12:08:56,417 DEBUG Accepted Ack of message: JmsInboundMessageDispatch {sequence = 5, messageId = ID::4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-5, consumerId = ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1} { 'redelivered' : False, 'reply_to' : None, 'id' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-5' , 'user_id' :None, 'correlation_id' : None, 'priority' : 4, 'durable' : True, 'ttl' : 0, 'type' : None, 'expiration' : 0, 'timestamp' : 1469182116869, 'address' : 'lala' , 'properties' : { 'JMSXDeliveryCount' : 1, 'NATIVE_MESSAGE_ID' : ':4ff32e1b-74f5-40be-8527-edb56d69e4c4:1:1:1-5' }, 'content' : None} 12:08:56,428 DEBUG AmqpConsumer { ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1:1 } is now closed: 12:08:56,433 DEBUG AmqpSession { ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1:1 } is now closed: 12:08:56,437 DEBUG AmqpConnection { ID::bce55db6-a65e-4c0b-b593-21ab6e555e1a:1 } is now closed: 12:08:56,441 DEBUG Shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@258e2e41[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] is shutdown: true and terminated: true took: 0.000 seconds. Correct numberOfMessages = 0 [0,root@r7x0_mtoth clients]$ java -jar / var /dtests/node_data/clients/amqx.jar queue -a properties -n lala { 'temporary' : False, 'numberOfBytesPerPage' : 10485760, 'paused' : False, 'messageCount' : 0, 'rolesAsJSON' : [{ 'createNonDurableQueue' : True, 'consume' : True, 'send' : True, 'deleteNonDurableQueue' : True, 'createDurableQueue' : True, 'name' : 'amq' , 'manage' : True, 'deleteDurableQueue' : True}], 'messagesAcknowledged' : 5, 'deadLetterAddress' : 'jms.queue.DLQ' , 'durable' : False, 'numberOfPages' : 0, 'deliveringCount' : 0, 'numberOfMessages' : 0, 'expiryAddress' : 'jms.queue.ExpiryQueue' , 'bindingNames' : [ 'lala' ], 'messagesAdded' : 5, 'address' : 'lala' , 'consumerCount' : 0, 'queueNames' : [ 'lala' ], 'scheduledCount' : 0, 'paging' : False, 'filter' : None, 'addressSize' : 0, 'firstMessageTimestamp' : None, 'name' : 'lala' , 'iD' : 16009, 'firstMessageAge' : None}
    • AMQ 7.0.2 sprint 1

      Transacted receiver with AMQ7 ER8 broker is unable to "clean queue" after messages are read from this queue and performed session.commit() action.
      Messages stay in the queue and can be re-read again. They should be marked as "read and purged" from the queue.
      With non-transacted receiver, queue is cleared out as expected (no messages in it).

      Different protocol, different client, but same JMS API for JMS Openwire client does session.commit() properly and cleans out the queue after reading.

              rh-ee-ataylor Andy Taylor
              mtoth@redhat.com Michal Toth
              Michal Toth Michal Toth
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

                Created:
                Updated:
                Resolved: