Обмен связыванием для обмена через весенний облачный поток с привязкой rabbitmq - PullRequest
0 голосов
/ 10 апреля 2019

Я ищу способ связать обмен RabbitMQ с другим через весенний облачный поток.Я знаю, что могу привязать очередь к обмену, установив свойство producer.requiredGroups:

spring.cloud.stream.bindings.foo.producer.requiredGroups=queueA queueB

Какое свойство можно использовать для создания привязки обмена к обмену?

1 Ответ

1 голос
/ 10 апреля 2019

Вместо добавления требуемой группы, добавьте @Bean s для двух обменов и @Bean для привязки.

См. Документацию Spring AMQP .

@Bean
public TopicExchange destinatioExchange() {
    return new TopicExchange("myDest");
}

@Bean
public DirectExchange boundExchange() {
    return new DirectExchange("bound");
}

@Bean
public Binding binding() {
    return BindingBuilder
            .bind(boundExchange())
            .to(destinatioExchange())
            .with("myRoutingKey");
}

и

spring.cloud.stream.bindings.output.destination=myDest
spring.cloud.stream.rabbit.bindings.output.producer.routing-key-expression='myRoutingKey'
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...