Как использовать одно сообщение?

Question

С example в rabbitmq потребитель получает все сообщения из очереди за один раз. Как использовать одно сообщение и выйти?

QueueingConsumer consumer = new QueueingConsumer(channel); 
channel.basicConsume(QUEUE_NAME, true, consumer); 

while (true) { 
    QueueingConsumer.Delivery delivery = consumer.nextDelivery(); 
    String message = new String(delivery.getBody()); 
    System.out.println(" [x] Received '" + message + "'"); 
} 

Answer 1

Вы должны объявить basicQos настройки, чтобы получить одно сообщение от времени ACK до NACK статуса и отключения автоматического ACK, чтобы дать подтверждение в явном виде.

ConnectionFactory factory = new ConnectionFactory(); 
    factory.setHost("localhost"); 
    Connection connection = factory.newConnection(); 
    Channel channel = connection.createChannel(); 
    channel.basicQos(1); 
    channel.queueDeclare(QUEUE_NAME, true, false, false, null); 
    System.out.println("[*] waiting for messages. To exit press CTRL+C"); 

    QueueingConsumer consumer = new QueueingConsumer(channel); 
    channel.basicConsume(QUEUE_NAME, consumer); 
    while(true) { 
     QueueingConsumer.Delivery delivery = consumer.nextDelivery(); 
     int n = channel.queueDeclarePassive(QUEUE_NAME).getMessageCount(); 
     System.out.println(n); 
     if(delivery != null) { 
      byte[] bs = delivery.getBody(); 
      System.out.println(new String(bs)); 
      //String message= new String(delivery.getBody()); 
      channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false); 
      //System.out.println("[x] Received '"+message); 
     } 
    } 

Надеюсь, это поможет!

Answer 2

Используйте AMQP 0.9.1 basic.get, чтобы синхронно получить только одно сообщение.

ConnectionFactory factory = new ConnectionFactory(); 
factory.setUri(uri); 

Connection connection = factory.newConnection(); 
Channel channel = connection.createChannel(); 

channel.queueDeclare(QUEUE_NAME, true, false, false, null); 

GetResponse response = channel.basicGet(QUEUE_NAME, true); 
if (response != null) { 
    String message = new String(response.getBody(), "UTF-8"); 
} 

channel.close(); 
connection.close();