使用Spring的现有队列

Question

我正在尝试使用AMQP编写一个Java应用程序来与RabbitMQ服务器对话。我必须使用现有的队列和交换，并且没有权利自己声明它们(我也不想)。问题是，我无法阻止Spring集成试图在RabbitMQ中声明队列，这将返回一个错误。

下面是从Wireshark发来的信息的截图：

Wireshark截图

我的主类使用@EnableBindings(Sink.class)注释进行注释。

下面是我的application.properties的相关部分：

spring.cloud.stream.bindings.input.group=********************.instana.test spring.cloud.stream.rabbit.bindings.input.consumer.bind-queue=false spring.cloud.stream.rabbit.bindings.input.consumer.queue-name-group-only=true spring.cloud.stream.rabbit.bindings.input.consumer.declare-exchange=false spring.cloud.stream.rabbit.bindings.input.consumer.durable-subscription=falsespring.cloud.stream.rabbit.bindings.input.consumer.exclusive=true

注意:我不想使用Spring的RabbitMQ特定实现，而是使用Spring云流解决方案。

Answer 1

目前无法阻止声明队列的尝试；但您可以简单地忽略该错误。

https://github.com/spring-cloud/spring-cloud-stream-binder-rabbit/issues/184