intprefetchCount = 1;

channel.basicQos(prefetchCount);

1. package cn.itcast.rabbitmq.durable;  

3. import com.rabbitmq.client.ConnectionFactory;  
4. import
    com.rabbitmq.client.Connection;  
5. import com.rabbitmq.client.Channel;  
6. import com.rabbitmq.client.QueueingConsumer;  

8. publicclass ClientReceive1  

9. {
10.     public static final String queue_name = "my_queue";  
11.     public static final boolean autoAck = false;  
12.     public static final boolean durable = true
    ;  
13.     public static void main(String[] args) throws java.io.IOException,  
14.         java.lang.InterruptedException  
15.     {  
16.         ConnectionFactory factory = new ConnectionFactory();  
17.         factory.setHost("localhost");  
18.         factory.setPort(5672);  
19. // 設定賬號資訊，使用者名稱、密碼、vhost
20.         factory.setVirtualHost("/taotao");  
21.     factory.setUsername("taotao");  
22.     factory.setPassword("taotao");  
23.     Connection connection = factory.newConnection();  
24.     Channel channel = connection.createChannel();  
25.     channel.queueDeclare(queue_name, durable, false, false, null);  
26.     System.out.println("Wait for message");  
27.     channel.basicQos(1); // 訊息分發處理
28.     QueueingConsumer consumer = new QueueingConsumer(channel);  
29.     channel.basicConsume(queue_name, autoAck, consumer);  
30.     while (true)  
31.     {  
32.         Thread.sleep(500);  
33.         QueueingConsumer.Delivery deliver = consumer.nextDelivery();  
34.         String message = new String(deliver.getBody());  
35.         System.out.println("Message received:" + message);  
36.         channel.basicAck(deliver.getEnvelope().getDeliveryTag(), false);  
37.     }  
38.     }  
39. }