Returning to the main topic of the thread. Here is a message by Gordon Sim from the other thread:
In AMQP 0-10 there are two levels of acknowledgement. The first involves accepting the message and your example code does that through the _session.messageAccept(_range); requests. Additionally there is a session level confirmation of completion. This completion controls flow control (as well as being used for managing session state). If your subscription is using windowing flow mode, then sending the completions is required. To send the completion I believe the following line alongside any messageAccept will work: _session.sessionCompleted(_range); Calling _session.sessionCompleted(_range) solves the problem with the 10000 messages limit. -- View this message in context: http://n2.nabble.com/10000-msgs-limit-per-session-tp4087077p4434866.html Sent from the Apache Qpid developers mailing list archive at Nabble.com. --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:dev-subscr...@qpid.apache.org