Uploaded image for project: 'JBoss A-MQ'
  1. JBoss A-MQ
  2. ENTMQ-1909

C++ client subscription on topic is receiving only the first message sent

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Done
    • Affects Version/s: JBoss A-MQ 6.3
    • Fix Version/s: JBoss A-MQ 6.3.x
    • Component/s: broker
    • Labels:
    • Environment:

      qpid-cpp-client-0.34-4
      AMQ-6.3.0 (-133, -159)

    • Steps to Reproduce:
      Hide
      1. start a broker with jmx enabled
      2. create a jmstopic 

        java  -jar /var/dtests/node_data/clients/amqx.jar  jmstopic --host localhost:1099 -broker-type activemq --action add --name "test_node_durable_msg_topic"

      3. Create a subscription on that topic 

        /var/dtests/node_data/clients/aac0_receiver --log-msgs dict --broker admin:admin@localhost --connection-options "{  protocol : 'amqp1.0' }" --address "'topic://test_node_durable_msg_topic'" --count 10 --timeout 120

      4. send several messages towards the topic 

        /var/dtests/node_data/clients/aac0_sender  --log-msgs dict --broker admin:admin@localhost --connection-options "{ protocol : 'amqp1.0' }" --address "'topic://test_node_durable_msg_topic'" --count 10

      5. only one message received by the subscription, receiver client did not finish execution (expected 10 messages)


      QE test that reproduces the issue:

      • JAMQNodeAac000Tests/test_node_durable_msg_topic
      Show
      start a broker with jmx enabled create a jmstopic java -jar /var/dtests/node_data/clients/amqx.jar jmstopic --host localhost: 1099 -broker-type activemq --action add --name "test_node_durable_msg_topic" Create a subscription on that topic /var/dtests/node_data/clients/aac0_receiver --log-msgs dict --broker admin:admin @localhost --connection-options "{ protocol : 'amqp1.0' }" --address "'topic://test_node_durable_msg_topic'" --count 10 --timeout 120 send several messages towards the topic /var/dtests/node_data/clients/aac0_sender --log-msgs dict --broker admin:admin @localhost --connection-options "{ protocol : 'amqp1.0' }" --address "'topic://test_node_durable_msg_topic'" --count 10 only one message received by the subscription, receiver client did not finish execution (expected 10 messages) QE test that reproduces the issue: JAMQNodeAac000Tests/test_node_durable_msg_topic

      Description

      When QE qpid-cpp client is used for a topic subscription, only the first message sent towards the topic is received by the subscription. This behaviour change was triggered by the broker upgrade to AMQ 6.3.0 and thus the issue is marked as regression.
      AMQ 6.2.1 broker do not suffer from that (all the messages sent are received by the subscription).

      This is probably somehow connected to the QE client implementation because when other client are used the issue does not appear. In example when qpid-receive or QE python proton client is used to consume the messages, everything works as expected and all the messages are received by the subscription. Therefore I don't see it as a blocker issue, but it's definitely a behaviour change that shall be revisited and explained.

      QE Qpid C++ clients sources:

        Gliffy Diagrams

          Attachments

            Issue Links

            causes

            Bug - A problem which impairs or prevents the functions of the product. ENTMQ-2012 [AMQ-6500] topic subs over AMQP limited by prefetch

            • Major - A request that should be considered seriously but is not a show stopper.
            • Resolved
            is duplicated by

            Bug - A problem which impairs or prevents the functions of the product. ENTMQCL-493 Qpid C++ client hangs in Receiver::fetch() with ActiveMQ 5.11 broker

            • Major - A request that should be considered seriously but is not a show stopper.
            • Closed

              Activity

                People

                • Assignee:
                  garytully Gary Tully
                  Reporter:
                  pematous Petr Matousek
                • Votes:
                  0 Vote for this issue
                  Watchers:
                  9 Start watching this issue

                  Dates

                  • Created:
                    Updated:
                    Resolved: