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-subscr...@qpid.apache.org