rabbitListener 在队列中没有消息时执行任务

Question

我们使用@RabbitListener 来监听队列，并在有消息时处理它们。但是，当队列为空时，我想执行一些报告任务，当我们的应用程序刚刚处理队列中的大量消息并且暂时没有消息时，就会发生这种情况。那是我要报告的时间。我怎么能用@RabbitListener 做到这一点？

这是我的代码：

@RabbitListener(queues = "${consumer.queue}", containerFactory = "ListenerContainerFactory")
    public void handleMessage(Message message) {
        processEvent(message);
    }

Answer 1

正如我answered your other question a few weeks ago 一样，AMQP（以及因此 Spring AMQP）中没有机制来通知消费者队列中当前没有消息。

我们可以修改容器以触发ApplicationEvent 一次，当处理完消息后未找到消息时，但这需要修改框架。您的侦听器必须实现 ApplicationListener 才能获得这样的事件。

如果您愿意，请随时打开New Feature JIRA Issue，我们或许可以查看一下。