Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- from("mqtt:test?subscribeTopicName=zaq.avila.send")
- //.process(new RestProcessor())
- .to("mqtt:test?publishTopicName=zaq.avila.receive");
- INFO | Waiting as there are still 1 inflight and pending exchanges to complete,
- timeout in 7 seconds.
- WARN | Error occurred while shutting down service: Endpoint[mqtt://test?publish
- TopicName=zaq.avila.receive]. This exception will be ignored.
- java.lang.NullPointerException
- Note: The component currently only supports polling (consuming) feeds.
- from("mqtt:test?subscribeTopicName=zaq.avila.send")
- .process(new RestProcessor())
- .to("jms:topic:zaq.avila.receive");
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement