Mailing-List: contact users-help@qpid.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@qpid.apache.org
MIME-Version: 1.0
From: Chester <knappch@gmail.com>
Date: Fri, 5 May 2017 16:52:44 -0400
Message-ID: <CAHVwL8u8fHPcXvSiHbtbENVqpmMOx7cwqbBA4+4MWq0akby_8g@mail.gmail.com>
Subject: cpp broker not respecting max-queue-count ?
To: users@qpid.apache.org
Content-Type: multipart/alternative; boundary=001a1149a5ee378867054ecd1263
archived-at: Fri, 05 May 2017 20:52:52 -0000

--001a1149a5ee378867054ecd1263
Content-Type: text/plain; charset=UTF-8

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})
    qmf_interface.send_message(QUEUE)
    qmf_interface.send_message(QUEUE)
except MessagingError, m:
    print m
except Exception, e:
    print 'Caught %s while setting up broker' % e
finally:
    qmf_interface.cleanup()

$ rpm -qa | grep qpid
qpid-tools-0.32-9.el7.noarch
qpid-cpp-client-1.35.0-3.el7.x86_64
qpid-cpp-server-1.35.0-3.el7.x86_64
python-qpid-0.32-12.el7.noarch
python-qpid-common-0.32-12.el7.noarch
qpid-proton-c-0.17.0-1.el7.x86_64
python-qpid-qmf-1.35.0-3.el7.x86_64
qpid-qmf-1.35.0-3.el7.x86_64
qpid-cpp-client-devel-1.35.0-3.el7.x86_64


Has anyone else seen this?

Thanks,
Chester

--001a1149a5ee378867054ecd1263--