commit | e78b84683097ac4755fd30f464b001a49552e0bb | [log] [tgz] |
---|---|---|
author | Claus Ibsen <claus.ibsen@gmail.com> | Tue Jan 12 16:45:20 2021 +0100 |
committer | Claus Ibsen <claus.ibsen@gmail.com> | Tue Jan 12 16:45:20 2021 +0100 |
tree | 81bc2b165da804ab9a50db7d634283812bd57aea | |
parent | 00309b07e05bbb30393fdc96d33bb2b003d3799c [diff] |
rabbitmq example should use the new spring-rabbitmq component
diff --git a/camel-example-spring-boot-rabbitmq/src/main/java/sample/camel/SampleCamelRouter.java b/camel-example-spring-boot-rabbitmq/src/main/java/sample/camel/SampleCamelRouter.java index 49183d7..739d86a 100644 --- a/camel-example-spring-boot-rabbitmq/src/main/java/sample/camel/SampleCamelRouter.java +++ b/camel-example-spring-boot-rabbitmq/src/main/java/sample/camel/SampleCamelRouter.java
@@ -33,6 +33,10 @@ .transform(simple("Random number ${random(0,100)}")) .to("spring-rabbitmq:foo?routingKey=mykey"); + from("timer:hello?period=2000") + .transform(simple("Bigger random number ${random(100,200)}")) + .to("spring-rabbitmq:foo?routingKey=mykey"); + from("spring-rabbitmq:foo?queues=myqueue&routingKey=mykey") .log("From RabbitMQ: ${body}"); }