Я пытаюсь написать приложение Java Spring Boot, используя AMQP для связи с сервером RabbitMQ.Я должен использовать существующие очереди и обмены и не имею права объявлять их сам (да и не хочу).Проблема в том, что я не могу удержать Spring Integrations от попытки объявить очередь в RabbitMQ, которая возвращает ошибку.
Вот скриншот сообщения, отправленного из Wireshark:
Wiresharkснимок экрана
Мой основной класс помечен аннотацией @EnableBindings (Sink.class).
Вот соответствующая часть моего приложения.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 = ложная пружина.cloud.stream.rabbit.bindings.input.consumer.durable-subscription = false spring.cloud.stream.rabbit.bindings.input.consumer.exclusive = true
Примечание. Я НЕ хочуиспользовать специфичные для RabbitMQ реализации Spring, а не решения для облачных потоков Spring.д.