It turns out that the MQTT component only supports consuming from that
endpoint. I figured out that I can consume a message as an MQTT message if I
send the message as a JMS. Like follows:
from("mqtt:test?subscribeTopicName=zaq.avila.send")
.process(new RestProcessor())
.to("jms:topic:zaq.avila.receive");
The MQTT subscriber receives the payload of the JMS message as the body of
the mqtt message. It works very well. I'm not sure what the shorthand of
approaching it this way are. If there are any, please let me know.
Thank you for addressing my question
--
View this message in context:
http://camel.465427.n5.nabble.com/Java-Route-Not-Finishing-tp5747047p5747273.html
Sent from the Camel - Users mailing list archive at Nabble.com.
