title: Camel and MQTT Route
body: <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>