[rabbitmq-discuss] does client caches messages?

Mohsen Lotfizad mtlotfizad at gmail.com
Sat May 11 12:42:30 BST 2013


I download the Recv.java<http://github.com/rabbitmq/rabbitmq-tutorials/blob/master/java/Recv.java>
and change some of its code to this:

*        ConnectionFactory factory = new ConnectionFactory();
         //factory.setHost("localhost");
        factory.setUri("amqp://guest:[email protected]:5672");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        channel.queueDeclarePassive(QUEUE_NAME);
        System.out.println(" [*] Waiting for messages. To exit press
CTRL+C");

        QueueingConsumer consumer = new QueueingConsumer(channel);
        channel.basicConsume(QUEUE_NAME, false, consumer);
        channel.basicQos(1);

**
*

On Sat, May 11, 2013 at 12:14 PM, Matthias Radestock
<matthias at rabbitmq.com>wrote:

> On 11/05/13 08:36, Mohsen Lotfizad wrote:
>
>> In fact I just want to know when I set prefetch_cont=2, why my consumer
>> try to give about 700 messages?
>>
>
> How is your consumer consuming messages? With basic.consume or basic.get?
> Prefetch does not apply to the latter since the client is explicitly asking
> for the next message.
>
> Matthias.
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130511/1cdf11d1/attachment.htm>


More information about the rabbitmq-discuss mailing list