Я ищу способ связать обмен RabbitMQ с другим через облачный поток Spring. Я знаю, что могу привязать очередь к обмену, установив свойство producer.requiredGroups
:
spring.cloud.stream.bindings.foo.producer.requiredGroups=queueA queueB
Какое свойство можно использовать для создания привязки обмена к обмену?
Вместо добавления необходимой группы добавьте @Bean
для двух обменов и @Bean
для привязки.
@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'