From 7188e5dce20e56e43314ed3f9c61c8717f961eff Mon Sep 17 00:00:00 2001 From: Antonio Terceiro Date: Sat, 30 Aug 2014 19:32:13 -0700 Subject: amqp-consume: support consuming N messages at a time MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit If you have a single consumer C₁ and 10 messages are published, all 10 will be streamed to that one customer. Assume each message takes a few minutes to be handled. If a second consumer C₂ comes up before C₁ is able to process its first message, it will stay idle until new messages are published, while C₁ will still have to process the other 9 messages after finishing with the first one. If both consumers were started with `--messages 1`, C₁ would only fetch a single message, and start handling it; C₂ would start and already receive the second message . --- tools/doc/amqp-consume.xml | 21 +++++++++++++++++++++ 1 file changed, 21 insertions(+) (limited to 'tools/doc') diff --git a/tools/doc/amqp-consume.xml b/tools/doc/amqp-consume.xml index f6f51ba..9ee12e8 100644 --- a/tools/doc/amqp-consume.xml +++ b/tools/doc/amqp-consume.xml @@ -160,6 +160,27 @@ + + + =limit + + + Request the server to only send + limit + messages at a time. + + + If any value was passed to , + the value passed to + should be smaller than that, or otherwise it will be + ignored. + + + If / is + passed, this option has no effect. + + + -- cgit v1.2.1