如何在 Micronaut 中以编程方式停止 RabbitListener

问题描述

我有一个 RabbitListener 看起来像：

@RabbitListener
public class ProductListener {

    @Queue(value = "product",executor = "product-listener") 
    public void receive(MyType message) {
        // process message
    }
}

在某些情况下，我想关闭我的应用程序。但是，在此之前，我想阻止 RabbitListner 消耗新消息，并给它一些时间来完成对已接收消息的处理。

在春天，根据 How to stop consuming messages with @RabbitListener 和 How to gracefully stop consuming messages with @RabbitListener，这应该可以通过 RabbitListenerEndpointRegistry#getListenerContainer(String) 实现。
我没有为 Micronaut 找到类似的东西。 Micronaut 可以做到这一点吗？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）