|
@@ -27,10 +27,10 @@ public class Recv {
|
|
|
System.out.println(" [x] Received '" + message + "'");
|
|
System.out.println(" [x] Received '" + message + "'");
|
|
|
};
|
|
};
|
|
|
/**
|
|
/**
|
|
|
- * 第一个参数是队列的名称
|
|
|
|
|
- * 第二个参数表示获取消息后是否自动响应消息被消费成功
|
|
|
|
|
- * 第三个参数是消息的处理回调方法
|
|
|
|
|
- * 第四个参数是消息被取消的回调方法
|
|
|
|
|
|
|
+ * 第一个参数(queue)是队列的名称
|
|
|
|
|
+ * 第二个参数(autoAck)表示获取消息后是否自动响应消息被消费成功
|
|
|
|
|
+ * 第三个参数(deliverCallback)是消息的处理回调方法
|
|
|
|
|
+ * 第四个参数(cancelCallback)是消息被取消的回调方法
|
|
|
*/
|
|
*/
|
|
|
//5.消费消息,会持续阻塞,等待消息队列有可以消费的消息
|
|
//5.消费消息,会持续阻塞,等待消息队列有可以消费的消息
|
|
|
channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> { });
|
|
channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> { });
|