Hi Slava,
On Thu, Dec 24, 2009 at 11:43 AM, <[email protected]> wrote: > Hi, > actually I do have subscribers, and also I specify queue policy as "ring" > ----------------------------------- > Map <String, Object> argument = new HashMap<String, Object>(); > argument.put("qpid.policy_type", "ring"); > argument.put("qpid.max_count", -1); > > session.queueDeclare(queueName, null, argument, Option.EXCLUSIVE, > Option.AUTO_DELETE); > session.exchangeBind(queueName, "amq.topic", bindingKey, null); > > --------------------------------- Well are you sure your subscribers are fast enough? Also it would be good to verify if the queue has the right policy as well. You could verify the details by using qpid-tool. qpid-tool is python based management tool. Look at the section called qpid-tool in the following location http://qpid.apache.org/mgmtc.html You can use that to look at a queue and see the policy (in the arguments section), current queue depth (in bytes and messages), the number of enqueues, dequeues and subscribers it has. qpid-tool should give you a clear idea as to whats going on with the queue. > > I added default-queue-limit=0 > to qpidd.conf, hope that would help in the interim. But the problem still > persists. If default-queue-limit is set to zero, then it will be treated as unlimited. But since you are still getting the exception I am wondering if your the broker is using your config file. > Btw, anybody have an estimate when M5 is coming out? 0.5 is already out. The 0.6 release is expected to go through during the first 2 weeks of Jan. > Regards, > Slava > > > > -----Original Message----- > From: "Rajith Attapattu" <[email protected]> > Sent: Wednesday, December 23, 2009 1:13pm > To: [email protected] > Subject: Re: RESOURCE_LIMIT_EXCEEDED exception - any advice? > > Hi Slava, > > You are getting that exception bcos your > "seg_orders1caa86344-19c7d-142a1-1b20e-107a0c16a2995" queue is > overflowing. > It seems either your subscriber(s) is slow or there is no subscriber > at all on this queue. > > Each queue has a limit (default is 104857600 bytes which is what you > are using) to protect the broker memory from growing. > > Regards, > > Rajith > > On Wed, Dec 23, 2009 at 12:38 PM, <[email protected]> wrote: >> Hi, >> I am using RedHat MRG 1.1, and Java client (M4) >> >> after some number of messages I am getting an exception: >> >> org.apache.qpid.transport.SessionException: ch=0 id=0 >> ExecutionException(errorCode=RESOURCE_LIMIT_EXCEEDED, commandId=146657, >> classCode=0, commandCode=0, fieldIndex=0, >> description=resource-limit-exceeded: Policy exceeded on >> seg_orders1caa86344-19c7d-142a1-1b20e-107a0c16a2995, policy: size: >> max=104857600, current=104857493; count: unlimited; type=reject >> (qpid/broker/QueuePolicy.cpp:83), errorInfo={}) >> >> >> Here is how I create session/queue: >> >> Map <String, Object> argument = new HashMap<String, Object>(); >> argument.put("qpid.policy_type", "ring"); >> argument.put("qpid.max_count", -1); >> >> session.queueDeclare(queueName, null, argument, Option.EXCLUSIVE, >> Option.AUTO_DELETE); >> session.exchangeBind(queueName, "amq.topic", bindingKey, null); >> >> >> session.messageSubscribe(queueName, queueName, >> MessageAcceptMode.NONE, >> MessageAcquireMode.PRE_ACQUIRED, >> null, 0, null); >> >> session.messageFlow(queueName, MessageCreditUnit.BYTE, >> Session.UNLIMITED_CREDIT); >> session.messageFlow(queueName, MessageCreditUnit.MESSAGE, >> Session.UNLIMITED_CREDIT); >> >> >> Questions: >> 1. What am I doing wrong? >> 2. If I am doing nothing wrong, RedHat recommends M4 Jave client on its >> site, should I use 0.6 or 0.6 instead? What potential problems would that >> bring? >> 3. Any other recommendations? >> >> Regards, >> Slava >> >> >> >> >> --------------------------------------------------------------------- >> Apache Qpid - AMQP Messaging Implementation >> Project: http://qpid.apache.org >> Use/Interact: mailto:[email protected] >> >> > > > > -- > Regards, > > Rajith Attapattu > Red Hat > http://rajith.2rlabs.com/ > > --------------------------------------------------------------------- > Apache Qpid - AMQP Messaging Implementation > Project: http://qpid.apache.org > Use/Interact: mailto:[email protected] > > > > > --------------------------------------------------------------------- > Apache Qpid - AMQP Messaging Implementation > Project: http://qpid.apache.org > Use/Interact: mailto:[email protected] > > -- Regards, Rajith Attapattu Red Hat http://rajith.2rlabs.com/ --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:[email protected]
