相关疑难解决方法(0)

如何在 spring-amqp 中设置消费者标签值

我正在尝试更新消费者标签,使其比随机生成的字符串提供更多信息。我们有一个我们使用的模式,其中包括主机名 + 标识符 + 随机字符串。这在我们的其他服务(即:NodeJS with ampqlib)中工作正常,因为它们提供了一种传递此值的机制。

但是,对于我们的 Java 服务,我们使用spring-amqp并且似乎无法传递消费者标签值。我看了一下,BlockingQueueConsumer它目前被硬编码为一个空字符串:

String consumerTag = this.channel.basicConsume(queue, this.acknowledgeMode.isAutoAck(), "", false, this.exclusive,
            this.consumerArgs, this.consumer);
Run Code Online (Sandbox Code Playgroud)

除了创建我们自己的消费者类型之外,有没有办法让它不是一个空字符串(这将导致一个随机生成的字符串)?

谢谢!

java amqp spring-amqp

5
推荐指数
1
解决办法
2769
查看次数

标签 统计

amqp ×1

java ×1

spring-amqp ×1