Advertisement
Guest User

Untitled

a guest
Jul 25th, 2014
164
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.65 KB | None | 0 0
  1. from("mqtt:test?subscribeTopicName=zaq.avila.send")
  2. //.process(new RestProcessor())
  3. .to("mqtt:test?publishTopicName=zaq.avila.receive");
  4.  
  5. INFO | Waiting as there are still 1 inflight and pending exchanges to complete,
  6. timeout in 7 seconds.
  7.  
  8. WARN | Error occurred while shutting down service: Endpoint[mqtt://test?publish
  9. TopicName=zaq.avila.receive]. This exception will be ignored.
  10. java.lang.NullPointerException
  11.  
  12. Note: The component currently only supports polling (consuming) feeds.
  13.  
  14. from("mqtt:test?subscribeTopicName=zaq.avila.send")
  15. .process(new RestProcessor())
  16. .to("jms:topic:zaq.avila.receive");
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement