1) Create new topic $ java -jar /var/dtests/node_data/clients/amqx.jar jmstopic -a add -n myTopic topic 'myTopic' created 2) Check its stats $ java -jar /var/dtests/node_data/clients/amqx.jar jmstopic {'myTopic': {'temporary': False, 'numberOfBytesPerPage': 10485760, 'messagesAdded': 0, 'messageCount': 0, 'address': 'jms.topic.myTopic', 'rolesAsJSON': [{'createNonDurableQueue': True, 'consume': True, 'send': True, 'deleteNonDurableQueue': True, 'createDurableQueue': True, 'name': 'amq', 'manage': True, 'deleteDurableQueue': True}], 'queueNames': ['jms.topic.myTopic'], 'subscriptionCount': 0, 'paging': False, 'nonDurableSubscriptionCount': 0, 'addressSize': 0, 'nonDurableMessageCount': 0, 'numberOfPages': 0, 'registryBindings': [], 'deliveringCount': 0, 'name': 'myTopic', 'numberOfMessages': 0, 'durableSubscriptionCount': 0, 'bindingNames': ['jms.topic.myTopic'], 'durableMessageCount': 0}} 3) Subscribe to this topic using AMQP client ./aac1_receiver.java.sh --log-msgs dict --broker localhost:5672 --conn-username admin --conn-password admin --address topic://jms.topic.myTopic [1250823499:0] -> Open{ containerId='ID::9d507286-cdaf-48e6-a973-1f3d9cc03be6:1', hostname='localhost', maxFrameSize=1048576, channelMax=32767, idleTimeOut=30000, outgoingLocales=null, incomingLocales=null, offeredCapabilities=null, desiredCapabilities=[sole-connection-for-container], properties={product=QpidJMS, version=0.8.0.redhat-1, platform=JVM: 1.8.0_71, 25.71-b15, Oracle Corporation, OS: Linux, 3.10.0-229.11.1.el7.x86_64, amd64}} [1250823499:0] <- Open{ containerId='', hostname='', maxFrameSize=4294967295, channelMax=65535, idleTimeOut=30000, outgoingLocales=null, incomingLocales=null, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1250823499:0] -> Begin{remoteChannel=null, nextOutgoingId=1, incomingWindow=2047, outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1250823499:0] <- Begin{remoteChannel=0, nextOutgoingId=1, incomingWindow=2147483647, outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1250823499:1] -> Begin{remoteChannel=null, nextOutgoingId=1, incomingWindow=2047, outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1250823499:1] <- Begin{remoteChannel=1, nextOutgoingId=1, incomingWindow=2147483647, outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1250823499:1] -> Attach{name='qpid-jms:receiver:ID::d657c118-c33f-404c-a084-0983c169a381:1:1:1:jms.topic.myTopic', handle=0, role=RECEIVER, sndSettleMode=UNSETTLED, rcvSettleMode=FIRST, source=Source{address='jms.topic.myTopic', durable=NONE, expiryPolicy=LINK_DETACH, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=Modified{deliveryFailed=true, undeliverableHere=null, messageAnnotations=null}, outcomes=[amqp:accepted:list, amqp:rejected:list, amqp:released:list, amqp:modified:list], capabilities=[topic]}, target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null}, unsettled=null, incompleteUnsettled=false, initialDeliveryCount=null, maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1250823499:1] <- Attach{name='qpid-jms:receiver:ID::d657c118-c33f-404c-a084-0983c169a381:1:1:1:jms.topic.myTopic', handle=0, role=SENDER, sndSettleMode=MIXED, rcvSettleMode=FIRST, source=Source{address='jms.topic.myTopic', durable=NONE, expiryPolicy=LINK_DETACH, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=Modified{deliveryFailed=true, undeliverableHere=null, messageAnnotations=null}, outcomes=[amqp:accepted:list, amqp:rejected:list, amqp:released:list, amqp:modified:list], capabilities=[topic]}, target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null}, unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0, maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1250823499:1] -> Flow{nextIncomingId=1, incomingWindow=2047, nextOutgoingId=1, outgoingWindow=2147483647, handle=0, deliveryCount=0, linkCredit=1000, available=null, drain=false, echo=false, properties=null} [1250823499:1] -> Flow{nextIncomingId=1, incomingWindow=2047, nextOutgoingId=1, outgoingWindow=2147483647, handle=0, deliveryCount=0, linkCredit=1000, available=null, drain=true, echo=false, properties=null} [1250823499:0] <- Empty Frame [1250823499:0] -> Empty Frame <Step 4 executed here> [1250823499:0] <- Empty Frame [1250823499:0] -> Empty Frame [1250823499:0] <- Empty Frame [1250823499:0] -> Empty Frame 4) Send a message to this topic using AMQP client $ ./aac1_sender.java.sh --log-msgs dict --broker localhost:5672 --conn-username admin --conn-password admin --address topic://jms.topic.myTopic --count 1 --msg-content "Simple Text Message" [1642558681:0] -> Open{ containerId='ID::8a2a7863-a5ec-45bf-bbd5-13cddf7330c1:1', hostname='localhost', maxFrameSize=1048576, channelMax=32767, idleTimeOut=30000, outgoingLocales=null, incomingLocales=null, offeredCapabilities=null, desiredCapabilities=[sole-connection-for-container], properties={product=QpidJMS, version=0.8.0.redhat-1, platform=JVM: 1.8.0_71, 25.71-b15, Oracle Corporation, OS: Linux, 3.10.0-229.11.1.el7.x86_64, amd64}} [1642558681:0] <- Open{ containerId='', hostname='', maxFrameSize=4294967295, channelMax=65535, idleTimeOut=30000, outgoingLocales=null, incomingLocales=null, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1642558681:0] -> Begin{remoteChannel=null, nextOutgoingId=1, incomingWindow=2047, outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1642558681:0] <- Begin{remoteChannel=0, nextOutgoingId=1, incomingWindow=2147483647, outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1642558681:1] -> Begin{remoteChannel=null, nextOutgoingId=1, incomingWindow=2047, outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1642558681:1] <- Begin{remoteChannel=1, nextOutgoingId=1, incomingWindow=2147483647, outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1642558681:1] -> Attach{name='qpid-jms:sender:ID::b15a6ff7-6209-4618-83ab-1ecda7e9f672:1:1:1:jms.topic.myTopic', handle=0, role=SENDER, sndSettleMode=UNSETTLED, rcvSettleMode=FIRST, source=Source{address='ID::b15a6ff7-6209-4618-83ab-1ecda7e9f672:1:1:1', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=null, outcomes=[amqp:accepted:list, amqp:rejected:list], capabilities=null}, target=Target{address='jms.topic.myTopic', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=[topic]}, unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0, maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1642558681:1] <- Attach{name='qpid-jms:sender:ID::b15a6ff7-6209-4618-83ab-1ecda7e9f672:1:1:1:jms.topic.myTopic', handle=0, role=RECEIVER, sndSettleMode=MIXED, rcvSettleMode=FIRST, source=Source{address='ID::b15a6ff7-6209-4618-83ab-1ecda7e9f672:1:1:1', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=null, outcomes=[amqp:accepted:list, amqp:rejected:list], capabilities=null}, target=Target{address='jms.topic.myTopic', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=[topic]}, unsettled=null, incompleteUnsettled=false, initialDeliveryCount=null, maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null, properties=null} [1642558681:1] <- Flow{nextIncomingId=1, incomingWindow=2147483647, nextOutgoingId=1, outgoingWindow=2147483647, handle=0, deliveryCount=0, linkCredit=200, available=null, drain=false, echo=false, properties=null} [1642558681:1] -> Transfer{handle=0, deliveryId=0, deliveryTag=0, messageFormat=0, settled=null, more=false, rcvSettleMode=null, state=null, resume=false, aborted=false, batchable=false} (168) "\x00Sp\xc0\x02\x01A\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x01\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0V\x0a\xa10ID::b15a6ff7-6209-4618-83ab-1ecda7e9f672:1:1:1-1@\xa1\x11jms.topic.myTopic@@@@@@\x83\x00\x00\x01TM\x9f!\x9c\x00Sw\xa1\x13Simple Text Message" [1642558681:1] <- Disposition{role=RECEIVER, first=0, last=0, settled=true, state=Accepted{}, batchable=false} {'redelivered': False, 'reply_to': None, 'id': ':b15a6ff7-6209-4618-83ab-1ecda7e9f672:1:1:1-1', 'user_id':None, 'correlation_id': None, 'priority': 4, 'durable': True, 'ttl': 0, 'type': None, 'expiration': 0, 'timestamp': 1461591155100, 'destination': 'jms.topic.myTopic', 'properties': {'JMSXDeliveryCount': 1}, 'content': 'Simple Text Message'} [1642558681:1] -> End{error=null} [1642558681:1] <- End{error=null} [1642558681:0] -> Close{error=null} [1642558681:0] <- Close{error=null} You can see, that in step 3, client is listening for messages in given topic, but nothing is received.