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);
---------------------------------
I added default-queue-limit=0
to qpidd.conf, hope that would help in the interim. But the problem still
persists.
Btw, anybody have an estimate when M5 is coming out?
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]
