问题标签 [micronaut-rabbitmq]

我在 Micronaut 中有一个消费者异常处理程序，如下所示

从侦听器方法中，我想抛出一个异常然后在上述方法中捕获。

Micronaut 库中的 RabbitListenerException 包含以下参数

我不确定如何从我的侦听器 Create 方法传递侦听器和messageState 。

更新 1

如果我不抛出异常，则以下语句中会出现 RXJava 异常 (io.reactivex.exceptions)

例外

RabbitListenerCustomExceptionHandler中没有捕获到上述异常

将 rabbitMQ 与 Micronaut 最新版本一起使用。在消费者上，两个参数都接受来自生产者的相同值，但是，我从生产者发送不同的值。

消费者的输出，因为 和 的categoryId值id相同

在生产者方面，我发送不同的值如下

和在生产者categoryId端id有不同的值

我做错了什么我不太确定。

我正在开发一个使用 Micronaut 并且需要使用 RabbitMQ 队列中的消息的应用程序。问题是队列可以提供很多消息，所以我想要一个参数化的消费者实例数。

例如以下代码自动生成一个消费者实例：

有没有办法告诉 micronaut 实例化多个实例？

我有一个看起来像的 RabbitListener：

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

在春天，这应该可以通过RabbitListenerEndpointRegistry#getListenerContainer(String)根据如何停止使用 @RabbitListener 消费消息和如何优雅地停止使用 @RabbitListener 消费消息来实现。
我没有为 Micronaut 找到类似的东西。Micronaut 可以做到这一点吗？

在应用程序开始时，我正在创建以下通道和相关队列

我想编写 JUnit 5 测试来检查队列是否已创建并使用 rabbitMq 测试容器绑定到交换。

从 RabbitMq java API，我知道我们有一个用于通道的方法。但不确定如何在 JUnit 5 中注入 Channel

io.micronaut.rabbitmq:micronaut-rabbitmq具有依赖关系的Micronaut 3.0.2 。

我想使用多个连接，然后使用建议ChannelPoolListener的基于io.micronaut.rabbitmq.connect.ChannelInitializer使用名为configbus.

我该怎么做呢？