2017-07-13 1 views
0

je tentais d'intercepter de/vers la route rabbitmq spécifique quelque chose comme ce qui suit, interceptFrom (? Rabbitmq: localhost/someExchangeName file d'attente = "somerRabbitMqQueueName") à ("log: bonjour");.interceptFrom et interceptSendToEndpoint ne fonctionne pas

et je ne reçois rien là. J'ai testé intercepter() à ("log: bonjour") et je peux confirmer que cela fonctionne, quelqu'un peut-il me faire savoir s'il y a quelque chose d'autre que j'ai besoin de configurer pour rendre l'interception de/à ?

Nous utilisons Java DSL et Google Guice pour l'injection de dépendance. Certains de la configuration du projet comme suit,

  • Version chameau: 2.18.3 (a aussi essayé 2.19.1)
  • chameau Guice: 2.18.3
  • Guice-multibindings: 4.1.0
  • chameau rabbitmq: 2.18.3
  • maven-plugin-compilateur: 1,7

Répondre

0

a également été demandé à ce sur la liste de diffusion Camel.

Assurez-vous qu'il peut correspondre à l'URL réelle, alors assurez-vous qu'ils sont exactement le même si vous n'utilisez pas wildcard (*), vous pouvez juste faire

interceptFrom("rabbitmq:localhost/xxx*") 

Ou essayez avec

interceptFrom("rabbitmq:localhost/xxx?queue=foo*") 
Voir aussi la documentation Camel et le motif générique (en bas de la page): http://camel.apache.org/intercept