On 05/05/17 21:52, Chester wrote:
Hi all,I am trying to create a queue with a message limit of 1, but the broker does not seem to be enforcing the limit. Repro steps: 1. $ qpidd --auth=no # start the cpp broker 2. $ python qmf-test.py # creates a ring queue with max-queue-count=1 and send 2 messages 3. $ qpid-stat -q # check the message count Expected: 1 message in the queue Actual: 2 messages in the queue $ qpid-stat -q Queues queue dur autoDel excl msg msgIn msgOut bytes bytesIn bytesOut cons bind ========================================================================================================================= b871cccb-fb46-4d67-a241-d35f9d899da3:0.0 Y Y 0 0 0 0 0 0 1 2 queue 2 2 0 62 62 0 0 1 $ qpid-config queues Queue Name Attributes ================================================================= 4845e801-c299-44c5-989a-58539c8c615c:0.0 auto-del excl queue --argument limit-policy=ring --argument max-queue-count=1 $ cat qmf-test.py #!/usr/bin/env python from qpid.messaging import * from qmf_interface import QmfInterface address = "localhost:5672" qmf_interface = QmfInterface(address, "Management", {}) QUEUE="queue" try: qmf_interface.create_queue(QUEUE, {'limit-policy': u'ring', 'max-queue-count': 1})
These are the wrong keys. Confusing, I know, as they are the command line options for qpid-config, but that tool converts to the real keys which are:
- qpid.max_count - qpid.policy_type --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
