> > Try setting flow control such that each consumer only gets one message at a > time. I.e. instead of calling start() on the incoming queue (which gives > unlimited credit) allocate credit yourself. (Attached patch attempts to > describe that more precisely). > > --Gordon. >
Thanks Gordon! That worked. So it seems the flow control will make the client receive one message at a time, right? However, after receiving just one message, the queue.get() is timing out. Do I need to do something else to continue receiving more messages one at a time? Regards, Ramashish --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:[email protected]
