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]
