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]
