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

Cannot receive from a durable subscription with qpid-python (AMQP)

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Obsolete
    • Icon: Major Major
    • None
    • AMQ 7.0.1.GA, AMQ 7.0.2.GA, AMQ 7.1.0.CR2
    • None
    • Hide

      Use default config, add ;multicastPrefix=topic:// to the amqp acceptor

      % git clone git@github.com:goochjs/amqp-python-go.git
% cd amqp-python-go/python-proton
% docker build -t producer -f Dockerfile-producer .
% docker build -t receiver -f Dockerfile-receiver .

# create durable subscription
% docker run --rm -it receiver --broker 172.17.0.1:5672 --topic lalatopic --subscription_name lalasubscription --max_messages 1
^C
# send message to it
% docker run --rm -it producer --broker 172.17.0.1:5672 --topic lalatopic --max_messages 1
# receive the message
% docker run --rm -it receiver --broker 172.17.0.1:5672 --topic lalatopic --subscription_name lalasubscription --max_messages 1

# expected:
[INFO] (MainThread) 1 messages received in 0:00:00.000121
# actual:
// nothing //
      Show
      Use default config, add ;multicastPrefix=topic:// to the amqp acceptor % git clone git@github.com:goochjs/amqp-python-go.git % cd amqp-python-go/python-proton % docker build -t producer -f Dockerfile-producer . % docker build -t receiver -f Dockerfile-receiver . # create durable subscription % docker run --rm -it receiver --broker 172.17.0.1:5672 --topic lalatopic --subscription_name lalasubscription --max_messages 1 ^C # send message to it % docker run --rm -it producer --broker 172.17.0.1:5672 --topic lalatopic --max_messages 1 # receive the message % docker run --rm -it receiver --broker 172.17.0.1:5672 --topic lalatopic --subscription_name lalasubscription --max_messages 1 # expected: [INFO] (MainThread) 1 messages received in 0:00:00.000121 # actual: // nothing //

      The durable subscription is created,
      messages are delivered to it (hawtio shows increasing message count on the subscription queue),
      but then the messages are not delivered to the consumer (but they are dequeued from the subscription queue)

      It is possible to receive the messages from the subscription queue using a different AMQP client, I tried qpid-jms.

      The steps to reproduce give expected result with upstream ActiveMQ Artemis, but fail with AMQ 7 Broker 7.0.1.

      The program from Reporoduction steps was discussed at https://www.mail-archive.com/users@qpid.apache.org/msg15753.html

            jross@redhat.com Justin Ross
            jdanek@redhat.com Jiri Daněk
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

              Created:
              Updated:
              Resolved: