RabbitMQ 메시지 확인 및 공정 스케줄링 소비자

QueueingConsumer consumer = new QueueingConsumer(channel);boolean autoAck = false;channel.basicConsume("hello", autoAck, consumer);

package com.zf.rabbitmq03;  
  
import java.io.IOException;  
  
import com.rabbitmq.client.Channel;  
import com.rabbitmq.client.Connection;  
import com.rabbitmq.client.ConnectionFactory;  
  
/** 
 *   
 * @author zhoufeng 
 * 
 */  
public class Sender03 {  
      
    public static void main(String[] args) throws IOException {  
          
          
        ConnectionFactory connFac = new ConnectionFactory() ;  
          
        //RabbitMQ-Server ， 127.0.0.1  
        connFac.setHost("127.0.0.1");  
          
        //   
        Connection conn = connFac.newConnection() ;  
          
        //   
        Channel channel = conn.createChannel() ;  
          
        // Queue   
        String queueName = "queue01" ;  
          
        // channel queue ，queueName Queue   
        channel.queueDeclare( queueName , false, false, false, null) ;  
          
        String msg = "Hello World!";  
          
        //   
        channel.basicPublish("", queueName , null , msg.getBytes());  
          
        System.out.println("send message[" + msg + "] to "+ queueName +" success!");  
          
        channel.close();   
        conn.close();   
          
    }  
  
}

package com.zf.rabbitmq03;  
  
import java.io.IOException;  
  
import com.rabbitmq.client.Channel;  
import com.rabbitmq.client.Connection;  
import com.rabbitmq.client.ConnectionFactory;  
import com.rabbitmq.client.ConsumerCancelledException;  
import com.rabbitmq.client.QueueingConsumer;  
import com.rabbitmq.client.QueueingConsumer.Delivery;  
import com.rabbitmq.client.ShutdownSignalException;  
  
/** 
 *   
 * @author zhoufeng 
 * 
 */  
public class Recv03 {  
  
    public static void main(String[] args) throws IOException, ShutdownSignalException, ConsumerCancelledException, InterruptedException {  
          
        ConnectionFactory connFac = new ConnectionFactory() ;  
          
        connFac.setHost("127.0.0.1");  
          
        Connection conn = connFac.newConnection() ;  
          
        Channel channel = conn.createChannel() ;  
          
        String channelName = "channel01";  
          
        channel.queueDeclare(channelName, false, false, false, null) ;  
          
          
        //   
        QueueingConsumer consumer = new QueueingConsumer(channel) ;  
          
  
        //  autoAck  
        boolean autoAck = false ;  
          
        channel.basicConsume(channelName, autoAck, consumer) ;  
          
        //   
        while(true){  
              
            // ， ，   
            Delivery delivery = consumer.nextDelivery() ;  
              
            String msg = new String(delivery.getBody()) ;    
              
            // ，   
            channel.basicAck(delivery.getEnvelope().getDeliveryTag()  
                    , false);  
              
            System.out.println("received message[" + msg + "] from " + channelName);  
        }  
          
    }  
      
}

boolean durable = true;channel.queueDeclare(channelName, durable, false, false, null);