如何解决如何在 Micronaut 中以编程方式停止 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 举报，一经查实，本站将立刻删除。
