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

Unable to receive message from topics using AMQP clients

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Blocker
    • A-MQ 7.0.0.ER7
    • None
    • None
    • Compatibility/Configuration, User Experience
    • Hide

      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.

      Show
      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.

    Description

      Messages sent to topics via AMQP clients are somehow lost in the broker. Subscribed clients are unable to receive them. Can this be also connected to ENTMQ-1573?
      Also, statistics about topic obtained via JMX or hawtio are not updated at all. Default initialization value of 0 is in all counters.

      Attachments

        Issue Links

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: