我正在寻找一种方法来检索未确认消息并将它们恢复为就绪状态，以便我的消费者可以再次发回这些消息。
我正在使用 java 客户端来获取消息，这些是我发送和检索消息的程序。我读到有一个方法 basicRecover() 会将消息放回队列中。
SendMessage
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare(QUEUE_NAME, true, false, false, null);
for(int i=0;i<1000;i++)
{
String message = "message goes here";
channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
System.out.println(" [x] Sent '" + message + "'");
}
channel.close();
connection.close();
}
Retrieve
try
{
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("10.4.4.19");
factory.setUsername("test");
factory.setPassword("test");
//factory.setPort(5267);
connection=factory.newConnection();
channel=connection.createChannel();
channel.basicQos(1);
QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume(QUEUE_NAME, false, consumer);
for(int i=0;i<1;i++)
{
QueueingConsumer.Delivery delivery = consumer.nextDelivery();
String message = new String(delivery.getBody());
System.out.println(" [x] Received '" + message + "'");
// Thread.currentThread().sleep(3000);
channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
}
channel.close();
connection.close();
}
catch(Exception e)
{
System.out.println("Error:"+e.getMessage());
e.printStackTrace();
}
任何人都可以给我一个代码片段，以便 unack 消息可以恢复到就绪状态，我可以使用我的检索 prog 来阅读它们。