qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rajith Attapattu <rajit...@gmail.com>
Subject Re: RESOURCE_LIMIT_EXCEEDED exception - any advice?
Date Wed, 23 Dec 2009 18:13:19 GMT
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,  <skuznetsov@segcap.com> 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:users-subscribe@qpid.apache.org
>
>



-- 
Regards,

Rajith Attapattu
Red Hat
http://rajith.2rlabs.com/

---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org


Mime
View raw message