qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chester <knap...@gmail.com>
Subject Re: cpp broker not respecting max-queue-count ?
Date Mon, 08 May 2017 14:55:05 GMT
Thanks, Gordon! That made the difference.

Is there a doc somewhere that I've overlooked that describes the available
keys?

On Mon, May 8, 2017 at 3:44 AM, Gordon Sim <gsim@redhat.com> wrote:

> 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: users-unsubscribe@qpid.apache.org
> For additional commands, e-mail: users-help@qpid.apache.org
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message