[root@rhel6.7-x86_64(msg-01) ~/dtests/dtests/node_data/clients/python] # java -jar /root/dtests/dtests/node_data/clients/java/amqx/target/amqx.jar queue -n jms.queue.test {'jms.queue.ExpiryQueue': {'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': 0, 'deadLetterAddress': 'jms.queue.DLQ', 'durable': True, 'numberOfPages': 0, 'deliveringCount': 0, 'numberOfMessages': 0, 'expiryAddress': 'jms.queue.ExpiryQueue', 'bindingNames': ['jms.queue.ExpiryQueue'], 'messagesAdded': 0, 'address': 'jms.queue.ExpiryQueue', 'consumerCount': 0, 'queueNames': ['jms.queue.ExpiryQueue'], 'scheduledCount': 0, 'paging': False, 'filter': None, 'addressSize': 0, 'firstMessageTimestamp': None, 'name': 'jms.queue.ExpiryQueue', 'iD': 4, 'firstMessageAge': None}, 'jms.queue.DLQ': {'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': 0, 'deadLetterAddress': 'jms.queue.DLQ', 'durable': True, 'numberOfPages': 0, 'deliveringCount': 0, 'numberOfMessages': 0, 'expiryAddress': 'jms.queue.ExpiryQueue', 'bindingNames': ['jms.queue.DLQ'], 'messagesAdded': 0, 'address': 'jms.queue.DLQ', 'consumerCount': 0, 'queueNames': ['jms.queue.DLQ'], 'scheduledCount': 0, 'paging': False, 'filter': None, 'addressSize': 0, 'firstMessageTimestamp': None, 'name': 'jms.queue.DLQ', 'iD': 2, 'firstMessageAge': None}} [root@rhel6.7-x86_64(msg-01) ~/dtests/dtests/node_data/clients/python] # ./aac5_sender.py --log-msgs dict -b localhost:5672/jms.queue.test --log-lib=TRANSPORT_FRM [0x210f390]: -> SASL [0x210f390]: <- SASL [0x210f390]:0 <- @sasl-mechanisms(64) [sasl-server-mechanisms=@PN_SYMBOL[:ANONYMOUS, :PLAIN]] [0x210f390]:0 -> @sasl-init(65) [mechanism=:ANONYMOUS, initial-response=b"anonymous"] [0x210f390]:0 <- @sasl-outcome(68) [code=0] [0x210f390]: -> AMQP [0x210f390]:0 -> @open(16) [container-id="2fbf6391-2b9e-49ff-b8f5-d326b41374bc", hostname="localhost:5672", channel-max=32767] [0x210f390]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647, outgoing-window=2147483647] [0x210f390]:0 -> @attach(18) [name="2fbf6391-2b9e-49ff-b8f5-d326b41374bc-jms.queue.test", handle=0, role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [durable=0, timeout=0, dynamic=false], target=@target(41) [address="jms.queue.test", durable=0, timeout=0, dynamic=false], initial-delivery-count=0] [0x210f390]: <- AMQP [0x210f390]:0 <- @open(16) [container-id="", hostname="", max-frame-size=4294967295, channel-max=65535, idle-time-out=30000] [0x210f390]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1, incoming-window=2147483647, outgoing-window=2147483647, handle-max=65535] [0x210f390]:0 <- @attach(18) [name="2fbf6391-2b9e-49ff-b8f5-d326b41374bc-jms.queue.test", handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [], target=@target(41) [address="jms.queue.test"]] [0x210f390]:0 <- @flow(19) [next-incoming-id=0, incoming-window=2147483647, next-outgoing-id=1, outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=200] {'address': None, 'annotations': None, 'body': None, 'content': None, 'content_encoding': 'None', 'content_type': 'text/plain', 'correlation_id': None, 'creation_time': 0.000000, 'delivery_count': 0, 'durable': False, 'expiry_time': 0.000000, 'first_acquirer': False, 'group_id': None, 'group_sequence': 0, 'id': None, 'inferred': False, 'instructions': None, 'priority': 4, 'properties': {}, 'reply_to': None, 'reply_to_group_id': None, 'subject': None, 'ttl': 0.000000, 'user_id': ''} [0x210f390]:0 -> @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"1", message-format=0, settled=false, more=false] (84) "\x00Sp\xd0\x00\x00\x00\x0b\x00\x00\x00\x05BP\x04@BR\x00\x00Ss\xd0\x00\x00\x00-\x00\x00\x00\x0d@@@@@@\xa3\x0atext/plain@\x83\x00\x00\x00\x00\x00\x00\x00\x00\x83\x00\x00\x00\x00\x00\x00\x00\x00@R\x00@\x00St\xd1\x00\x00\x00\x04\x00\x00\x00\x00" [0x210f390]:0 <- @disposition(21) [role=true, first=0, last=0, settled=true, state=@accepted(36) []] [0x210f390]:0 -> @detach(22) [handle=0, closed=true] [0x210f390]:0 -> @close(24) [] [0x210f390]: -> EOS [0x210f390]:0 <- @detach(22) [handle=0, closed=true] [0x210f390]:0 <- @close(24) [] [0x210f390]: <- EOS [root@rhel6.7-x86_64(msg-01) ~/dtests/dtests/node_data/clients/python] # java -jar /root/dtests/dtests/node_data/clients/java/amqx/target/amqx.jar queue -n jms.queue.test {'jms.queue.test': {'temporary': False, 'numberOfBytesPerPage': 10485760, 'paused': False, 'messageCount': 1, 'rolesAsJSON': [{'createNonDurableQueue': True, 'consume': True, 'send': True, 'deleteNonDurableQueue': True, 'createDurableQueue': True, 'name': 'amq', 'manage': True, 'deleteDurableQueue': True}], 'deadLetterAddress': 'jms.queue.DLQ', 'messagesAcknowledged': 0, 'durable': True, 'numberOfPages': 0, 'deliveringCount': 0, 'numberOfMessages': 1, 'expiryAddress': 'jms.queue.ExpiryQueue', 'bindingNames': ['jms.queue.test'], 'messagesAdded': 1, 'address': 'jms.queue.test', 'consumerCount': 0, 'queueNames': ['jms.queue.test'], 'scheduledCount': 0, 'paging': False, 'filter': None, 'addressSize': 1158, 'firstMessageTimestamp': 0, 'name': 'jms.queue.test', 'iD': 6, 'firstMessageAge': 1461932421750}, 'jms.queue.ExpiryQueue': {'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}], 'deadLetterAddress': 'jms.queue.DLQ', 'messagesAcknowledged': 0, 'durable': True, 'numberOfPages': 0, 'deliveringCount': 0, 'numberOfMessages': 0, 'expiryAddress': 'jms.queue.ExpiryQueue', 'bindingNames': ['jms.queue.ExpiryQueue'], 'messagesAdded': 0, 'address': 'jms.queue.ExpiryQueue', 'consumerCount': 0, 'queueNames': ['jms.queue.ExpiryQueue'], 'scheduledCount': 0, 'paging': False, 'filter': None, 'addressSize': 0, 'firstMessageTimestamp': None, 'name': 'jms.queue.ExpiryQueue', 'iD': 4, 'firstMessageAge': None}, 'jms.queue.DLQ': {'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}], 'deadLetterAddress': 'jms.queue.DLQ', 'messagesAcknowledged': 0, 'durable': True, 'numberOfPages': 0, 'deliveringCount': 0, 'numberOfMessages': 0, 'expiryAddress': 'jms.queue.ExpiryQueue', 'bindingNames': ['jms.queue.DLQ'], 'messagesAdded': 0, 'address': 'jms.queue.DLQ', 'consumerCount': 0, 'queueNames': ['jms.queue.DLQ'], 'scheduledCount': 0, 'paging': False, 'filter': None, 'addressSize': 0, 'firstMessageTimestamp': None, 'name': 'jms.queue.DLQ', 'iD': 2, 'firstMessageAge': None}} [root@rhel6.7-x86_64(msg-01) ~/dtests/dtests/node_data/clients/python] # ./aac5_receiver.py --log-msgs dict -b localhost:5672/jms.queue.test --log-lib=TRANSPORT_FRM [0x1c08ef0]: -> SASL [0x1c08ef0]: <- SASL [0x1c08ef0]:0 <- @sasl-mechanisms(64) [sasl-server-mechanisms=@PN_SYMBOL[:ANONYMOUS, :PLAIN]] [0x1c08ef0]:0 -> @sasl-init(65) [mechanism=:ANONYMOUS, initial-response=b"anonymous"] [0x1c08ef0]:0 <- @sasl-outcome(68) [code=0] [0x1c08ef0]: -> AMQP [0x1c08ef0]:0 -> @open(16) [container-id="9acf8fa2-188a-4016-b429-e9884d93e599", hostname="localhost:5672", channel-max=32767] [0x1c08ef0]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647, outgoing-window=2147483647] [0x1c08ef0]:0 -> @attach(18) [name="9acf8fa2-188a-4016-b429-e9884d93e599-jms.queue.test", handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [address="jms.queue.test", durable=0, timeout=0, dynamic=false], target=@target(41) [durable=0, timeout=0, dynamic=false], initial-delivery-count=0] [0x1c08ef0]:0 -> @flow(19) [incoming-window=2147483647, next-outgoing-id=0, outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=10, drain=false] [0x1c08ef0]: <- AMQP [0x1c08ef0]:0 <- @open(16) [container-id="", hostname="", max-frame-size=4294967295, channel-max=65535, idle-time-out=30000] [0x1c08ef0]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1, incoming-window=2147483647, outgoing-window=2147483647, handle-max=65535] [0x1c08ef0]:0 <- @attach(18) [name="9acf8fa2-188a-4016-b429-e9884d93e599-jms.queue.test", handle=0, role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [address="jms.queue.test"], target=@target(41) [], incomplete-unsettled=false, initial-delivery-count=0] [0x1c08ef0]:0 -> @flow(19) [next-incoming-id=1, incoming-window=2147483647, next-outgoing-id=0, outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=10, drain=true] ^CTraceback (most recent call last): File "./aac5_receiver.py", line 316, in main() File "./aac5_receiver.py", line 309, in main proton.reactor.Container(Recv(opts)).run() File "/usr/lib64/python2.6/site-packages/proton/reactor.py", line 133, in run while self.process(): pass File "/usr/lib64/python2.6/site-packages/proton/reactor.py", line 156, in process self._check_errors() File "/usr/lib64/python2.6/site-packages/proton/reactor.py", line 152, in _check_errors _compat.raise_(exc, value, tb) File "/usr/lib64/python2.6/site-packages/proton/__init__.py", line 4016, in dispatch ev.dispatch(self.handler) File "/usr/lib64/python2.6/site-packages/proton/__init__.py", line 3925, in dispatch result = dispatch(handler, type.method, self) File "/usr/lib64/python2.6/site-packages/proton/__init__.py", line 3808, in dispatch return handler.on_unhandled(method, *args) File "/usr/lib64/python2.6/site-packages/proton/reactor.py", line 483, in on_unhandled event.dispatch(self.base) File "/usr/lib64/python2.6/site-packages/proton/__init__.py", line 3923, in dispatch pn_handler_dispatch(handler._impl, self._impl, type.number) KeyboardInterrupt [root@rhel6.7-x86_64(msg-01) ~/dtests/dtests/node_data/clients/python] # java -jar /root/dtests/dtests/node_data/clients/java/amqx/target/amqx.jar queue -n jms.queue.test {'jms.queue.test': {'temporary': False, 'numberOfBytesPerPage': 10485760, 'paused': False, 'messageCount': 2, 'rolesAsJSON': [{'createNonDurableQueue': True, 'consume': True, 'send': True, 'deleteNonDurableQueue': True, 'createDurableQueue': True, 'name': 'amq', 'manage': True, 'deleteDurableQueue': True}], 'messagesAcknowledged': 0, 'deadLetterAddress': 'jms.queue.DLQ', 'durable': True, 'numberOfPages': 0, 'deliveringCount': 1, 'numberOfMessages': 2, 'expiryAddress': 'jms.queue.ExpiryQueue', 'bindingNames': ['jms.queue.test'], 'messagesAdded': 1, 'address': 'jms.queue.test', 'consumerCount': 0, 'queueNames': ['jms.queue.test'], 'scheduledCount': 0, 'paging': False, 'filter': None, 'addressSize': 1158, 'firstMessageTimestamp': 0, 'name': 'jms.queue.test', 'iD': 6, 'firstMessageAge': 1461932442967}, 'jms.queue.ExpiryQueue': {'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': 0, 'deadLetterAddress': 'jms.queue.DLQ', 'durable': True, 'numberOfPages': 0, 'deliveringCount': 0, 'numberOfMessages': 0, 'expiryAddress': 'jms.queue.ExpiryQueue', 'bindingNames': ['jms.queue.ExpiryQueue'], 'messagesAdded': 0, 'address': 'jms.queue.ExpiryQueue', 'consumerCount': 0, 'queueNames': ['jms.queue.ExpiryQueue'], 'scheduledCount': 0, 'paging': False, 'filter': None, 'addressSize': 0, 'firstMessageTimestamp': None, 'name': 'jms.queue.ExpiryQueue', 'iD': 4, 'firstMessageAge': None}, 'jms.queue.DLQ': {'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': 0, 'deadLetterAddress': 'jms.queue.DLQ', 'durable': True, 'numberOfPages': 0, 'deliveringCount': 0, 'numberOfMessages': 0, 'expiryAddress': 'jms.queue.ExpiryQueue', 'bindingNames': ['jms.queue.DLQ'], 'messagesAdded': 0, 'address': 'jms.queue.DLQ', 'consumerCount': 0, 'queueNames': ['jms.queue.DLQ'], 'scheduledCount': 0, 'paging': False, 'filter': None, 'addressSize': 0, 'firstMessageTimestamp': None, 'name': 'jms.queue.DLQ', 'iD': 2, 'firstMessageAge': None}}