Camel and MQTT Route <p>I am working on a project and have decided to use Camel and ActiveMQ. I am attempting to create a route using Java and MQTT endpoints. Within this route I have also incorporated a Processor. This is what my route looks like:</p> <pre><code>from("mqtt:test?subscribeTopicName=zaq.avila.send") //.process(new RestProcessor()) .to("mqtt:test?publishTopicName=zaq.avila.receive"); </code></pre> <p>From my understanding, the route is consuming from zaq/avila/send, a processor is applied and then the message is published to zaq/avila/receive. The to() part does not appear to be happening, when I check the console, I see that the processor executes though no message is published to zaq/avila/receive. Also, within the web console I see that the messages in zaq/avila/send for enqueued and dequeued increment even when I only pusblished one message. In addition, if I shutdown ActiveMQ I get the following:</p> <pre><code> INFO | Waiting as there are still 1 inflight and pending exchanges to complete, timeout in 7 seconds. </code></pre> <p>Also:</p> <pre><code> WARN | Error occurred while shutting down service: Endpoint[mqtt://test?publish TopicName=zaq.avila.receive]. This exception will be ignored. java.lang.NullPointerException </code></pre> <p>These exception make me wonder that the exchange is not completing and something is missing. I need help!</p>