RabbitMQ消息到期通知

Question

有没有一种方法可以将消息推送到RabbitMQ并有一个到期时间，一旦到期，它应该提供通知。要么是否有一种方法可以在一定时间后在RabbitMQ中传递消息。例如，我要在队列中推送一条消息，并希望它在10秒后得到传递，并同时发送下一条消息。

Answer 1

RabbitMQ延迟消息插件向RabbitMQ添加了新的交换类型，如果用户选择这样做，则可以延迟该交换路由的消息。

您可以按如下所述的方式使用它。

// ... elided code ...
Map<String, Object> args = new HashMap<String, Object>();
args.put("x-delayed-type", "direct");
channel.exchangeDeclare("my-exchange", "x-delayed-message", true, false, args);
// ... more code ...