带有rabbit mq的Micronaut将消息从生产者发送到消费者，在消费者端它接受相同的参数值

Question

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

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

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

  @RabbitProperty(name = "replyTo", value = "amq.rabbitmq.reply-to")
    @Binding(ConstantValues.COUNT_SUB_CATEGORY)
    Maybe<Long> Count(@MessageHeader String categoryId, String id);

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

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

Answer 1

这很奇怪。我也在我的系统上复制了这个问题。而且，当使用已弃用的 io.micronaut.messaging.annotation.Header 时，此问题似乎消失了。

您也可以在您的代码上尝试一下，看看它是否有效？

您的新代码：

制作人：

@Binding(ConstantValues.COUNT_SUB_CATEGORY)
Maybe<Long> Count(@Header String categoryId, String id);

消费者：

@Queue(......)
Long count(@Header("categoryId") String categoryId, String id) {
    ......
}

使用 micronaut 版本 2.5.1、micronaut-rabbitmq 2.5.0、java 11 测试

Answer 2

此问题现已在此https://github.com/micronaut-projects/micronaut-core/issues/5588 中得到修复