版本: Spring Boot: 1.4.2发布Spring Cloud Deps: Brixton.SR7
这是我的一个处理器应用的application.properties。
logging.level.=DEBUG
server.port=0
logging.file=traveller-events-processor.log
server.port=0
spring.cloud.stream.rabbit.bindings.input.consumer.bindingRoutingKey='aa'
spring.cloud.stream.rabbit.bindings.input.consumer.bindingRoutingKey=aa
spring.cloud.stream.rabbit.bindings.input.consumer.bindQueue=true
spring.cloud.stream.rabbit.bindings.input.consumer.routing-key='aa'
spring.cloud.stream.rabbit.bindings.input.consumer.routingKey='aa'
spring.cloud.stream.bindings.input.destination=events-exchange
spring.cloud.stream.bindings.input.group=eventconsumersgroup
spring.cloud.stream.bindings.output.destination=work.out
spring.cloud.stream.bindings.output.contentType=text/plain
spring.cloud.stream.bindings.output.binder=rabbit
spring.cloud.stream.bindings.output.group=traveller-events-output-group当我启动这个应用程序时,events-exchange如期创建并绑定到一个名为events-exchange.eventconsumersgroup的队列(这也没问题)。但是routingKey始终是'#‘。我已经尝试了从各种文档中搜索到的所有选项。我是不是漏掉了什么?
我希望这个应用程序只订阅某些消息(我想通过路由关键字来实现)。
发布于 2017-07-20 16:49:28
我看到Brixton.SR7使用Spring Cloud Stream的1.0.2.RELEASE,而我似乎没有找到routingKey作为Rabbit的消费者属性。您想升级到Spring Cloud Camden发行版还是最新版本,这样您就可以尝试使用前面提到的here的消费者属性:bindingRoutingKey
https://stackoverflow.com/questions/45207052
复制相似问题