问题标签 [micronaut-rabbitmq]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - 从 Micronaut 的 Listener 方法中抛出 RabbitListenerException
我在 Micronaut 中有一个消费者异常处理程序,如下所示
从侦听器方法中,我想抛出一个异常然后在上述方法中捕获。
Micronaut 库中的 RabbitListenerException 包含以下参数
我不确定如何从我的侦听器 Create 方法传递侦听器和messageState 。
更新 1
如果我不抛出异常,则以下语句中会出现 RXJava 异常 (io.reactivex.exceptions)
例外
RabbitListenerCustomExceptionHandler中没有捕获到上述异常
rabbitmq - Micronaut 和 RabbitMQ
我正在开发一个使用 Micronaut 并且需要使用 RabbitMQ 队列中的消息的应用程序。问题是队列可以提供很多消息,所以我想要一个参数化的消费者实例数。
例如以下代码自动生成一个消费者实例:
有没有办法告诉 micronaut 实例化多个实例?
java - 如何以编程方式停止 Micronaut 中的 RabbitListener
我有一个看起来像的 RabbitListener:
在某些情况下,我想关闭我的应用程序。但是,在这样做之前,我想阻止 RabbitListner 使用新消息并给它一些时间来完成对已收到消息的处理。
在春天,这应该可以通过RabbitListenerEndpointRegistry#getListenerContainer(String)
根据如何停止使用 @RabbitListener 消费消息和如何优雅地停止使用 @RabbitListener 消费消息来实现。
我没有为 Micronaut 找到类似的东西。Micronaut 可以做到这一点吗?
java - 如何使用 Micronaut 中的 rabbitMq TestContainer 测试是否创建了通道和队列并绑定到 rabbitMq 中的交换
在应用程序开始时,我正在创建以下通道和相关队列
我想编写 JUnit 5 测试来检查队列是否已创建并使用 rabbitMq 测试容器绑定到交换。
从 RabbitMq java API,我知道我们有一个用于通道的方法。但不确定如何在 JUnit 5 中注入 Channel
micronaut - Micronaut:存在多个连接时如何在 ChannelPoolListener 中创建队列
io.micronaut.rabbitmq:micronaut-rabbitmq
具有依赖关系的Micronaut 3.0.2 。
我想使用多个连接,然后使用建议ChannelPoolListener
的基于io.micronaut.rabbitmq.connect.ChannelInitializer
使用名为configbus
.
我该怎么做呢?