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

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}