[rabbitmq-discuss] Consuming multiple messages at a time

Vijay Lakshmi vijjivinay at gmail.com
Tue Jun 4 18:45:12 BST 2013


Hi,

We have an application where in for each client we create a Queue in
RabbitMQ.
(i.e. we create a binding with client id to a common exchange)
So, all messages that are published with binding key as client id will go
to that queue.

There is only single client which subscribes to this Queue.
The queue will get messages at the rate of 100 msgs/sec for example.

RabbitMQ is sending only 1 message at a time to the consumer. Even if we
set the prefetch count as higher value, the messages are delivered only one
by one.
The callback method in consumer can consume only single message.

void *handleDelivery*(java.lang.String consumerTag,
                    Envelope
<http://www.rabbitmq.com/releases/rabbitmq-java-client/v3.1.1/rabbitmq-java-client-javadoc-3.1.1/com/rabbitmq/client/Envelope.html>
envelope,
                    AMQP.BasicProperties
<http://www.rabbitmq.com/releases/rabbitmq-java-client/v3.1.1/rabbitmq-java-client-javadoc-3.1.1/com/rabbitmq/client/AMQP.BasicProperties.html>
properties,
                    byte[] body)
                    throws java.io.IOException

Is there a way in RabbitMQ where in we enable RabbitMQ to send mutiple
messages to consumer at a time. In my case there is only one consumer per
queue. So, by sending mutiple messages to consumer at a time will improve
my performance.

Can someone suggest how I can achieve this.
If rabbitMQ does not support, is there any other way of achieving this.
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130604/8b872944/attachment.htm>


More information about the rabbitmq-discuss mailing list