1

Version: Spring Boot: 1.4.2.RELEASE printemps Nuage Deps: Brixton.SR7Nuage Spring flux lapin Binder Routing Key toujours '#'

Voici mes application.properties d'une application de processeur.

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 

Quand je commence cette application, les événements d'échange est créé comme prévu et lié à une file d'attente nommée: événements exchange.eventconsumersgroup (qui est aussi ok). Mais le routingKey est toujours '#'. J'ai essayé avec toutes les options que j'ai pêchées à partir de diverses documentations. Est-ce que j'ai râté quelque chose?

Je veux que cette application s'abonne uniquement à certains messages (que je veux atteindre via la clé de routage).

Répondre

2

Je vois que Brixton.SR7 utilise la version 1.0.2.RELEASE de Spring Cloud Stream et je ne trouve pas le routingKey comme propriété de consommation Rabbit. Voulez-vous passer à la version Spring Cloud Camden ou la dernière version pour pouvoir utiliser la propriété grand public: bindingRoutingKey comme indiqué here

+0

Cheers! C'est un problème de décalage de version. – user1189332