Message Title

Sending a message through the camel-mqtt reference binding fails with following error. The MQTTProducerTest unit test in the camel-mqtt also fails with a same error (this test is disabled by default), so it seems to be a known issue and the root cause is in camel-mqtt or fusesource mqtt-client.
&amp;#27;[0m&amp;#27;[31m18:06:27,482 ERROR [org.switchyard.bus.camel.DefaultErrorListener] (hawtdispatch-DEFAULT-2) 
------- Begin Message Trace -------
Consumer -&gt; {urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference
Provider -&gt; {urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}StoreReference
Operation -&gt; greet
MEP -&gt; IN_ONLY
Phase -&gt; IN
State -&gt; OK
Exchange Context -&gt; 
    CamelCreatedTimestamp ............................: Thu Jul 17 18:06:27 JST 2014
    CamelExceptionCaught .............................: org.switchyard.HandlerException: org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchange[Message: Hello there SpongeBob :-) ]
    CamelExceptionHandled ............................: true
    CamelFailureEndpoint .............................: direct://%7Burn:switchyard-quickstart:camel-mqtt-binding:0.1.0%7DGreetingService/StoreReference
    CamelFilterMatched ...............................: false
    CamelMessageHistory ..............................: [DefaultMessageHistory[routeId=direct:{urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, node=doTry1], DefaultMessageHistory[routeId=direct:{urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, node=filter1], DefaultMessageHistory[routeId=direct:{urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, node=process1], DefaultMessageHistory[routeId=direct:{urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, node=process2], DefaultMessageHistory[routeId=direct:{urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, node=process3], DefaultMessageHistory[routeId=direct:{urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, node=process4], DefaultMessageHistory[routeId=direct:{urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, node=process5], DefaultMessageHistory[routeId=direct:{urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, node=process6], DefaultMessageHistory[routeId=direct:{urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, node=process7], DefaultMessageHistory[routeId=direct:{urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, node=process8], DefaultMessageHistory[routeId=direct:{urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, node=process9], DefaultMessageHistory[routeId=direct:{urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, node=process10], DefaultMessageHistory[routeId=direct:{urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, node=process17]]
    CamelToEndpoint ..................................: direct://%7Burn:switchyard-quickstart:camel-mqtt-binding:0.1.0%7DGreetingService/StoreReference
    org.switchyard.bus.camel.consumer ................: ServiceReference [name={urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference, interface=BaseServiceInterface [type=java, operations=[greet : IN_ONLY  : [java:java.lang.String, null, null]]], domain=ServiceDomain [name=null]]
    org.switchyard.bus.camel.contract ................: org.switchyard.metadata.BaseExchangeContract@744804c3
    org.switchyard.bus.camel.dispatcher ..............: org.switchyard.bus.camel.ExchangeDispatcher@55f029d0
    org.switchyard.bus.camel.labels ..................: {org.switchyard.exchangeGatewayName=[org.switchyard.label.behavior.transient], org.switchyard.exchangeInitiatedNS=[org.switchyard.label.behavior.transient], org.switchyard.exchange.transaction.beforeInvoked=[org.switchyard.label.behavior.transient], org.switchyard.security.context.SecurityContext=[org.switchyard.label.behavior.transient]}
    org.switchyard.bus.camel.phase ...................: IN
    org.switchyard.bus.camel.provider ................: Service [name={urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}StoreReference, interface=BaseServiceInterface [type=java, operations=[greet : IN_ONLY  : [java:java.lang.String, null, null]]], domain=ServiceDomain [name=null], metadata=org.switchyard.metadata.ServiceMetadataBuilder$ServiceMetadataImpl@436e55df]
    org.switchyard.exchange.transaction.beforeInvoked : true
    org.switchyard.exchangeGatewayName ...............: Store
    org.switchyard.exchangeInitiatedNS ...............: 131218611009591
    org.switchyard.security.context.SecurityContext ..: DefaultSecurityContext@13092367[systemUUID=bb8125a8-06a3-4c36-bced-3471b3b94864, expirationMillis=0, credentials=[], securityDomainsToSubjects={other=Subject:
        Principal: GroupPrincipal@604308401[name=Roles, members=[]]
}]
Message Context -&gt; 
    breadcrumbId ..............................: ID-tomo-t530-47944-1405587984047-0-5
    org.switchyard.bus.camel.labels ...........: {org.switchyard.contentType=[org.switchyard.label.behavior.transient], org.switchyard.bus.camel.messageSent=[org.switchyard.label.behavior.transient], org.switchyard.transform.TransformSequence=[org.switchyard.label.behavior.transient]}
    org.switchyard.bus.camel.messageSent ......: true
    org.switchyard.contentType ................: java:java.lang.String
    org.switchyard.messageId ..................: ID-tomo-t530-47944-1405587984047-0-5
    org.switchyard.transform.TransformSequence : org.switchyard.transform.TransformSequence@6ab833fe
------ End Message Trace -------
Caught exception of type org.switchyard.HandlerException with message: org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchange[Message: Hello there SpongeBob :-) ]
  Caused by exception of type org.apache.camel.CamelExecutionException, message: Exception occurred during execution on the exchange: Exchange[Message: Hello there SpongeBob :-) ]
    Caused by exception of type java.lang.AssertionError, message: Dispatch queue &apos;mqtt client&apos; was not executing, (currently executing: &apos;mqtt client&apos;): org.switchyard.HandlerException: org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchange[Message: Hello there SpongeBob :-) ]
        at org.switchyard.component.camel.common.handler.OutboundHandler.handleInOnly(OutboundHandler.java:163) [switchyard-component-common-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.component.camel.common.handler.OutboundHandler.handleMessage(OutboundHandler.java:145) [switchyard-component-common-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.handlers.ProviderHandler.handleMessage(ProviderHandler.java:77) [switchyard-runtime-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.bus.camel.processors.HandlerProcessor.process(HandlerProcessor.java:61) [switchyard-bus-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.apache.camel.processor.DelegateSyncProcessor.process(DelegateSyncProcessor.java:63) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91) [camel-core-2.12.2.jar:2.12.2]
        at org.switchyard.bus.camel.audit.FaultProcessor.process(FaultProcessor.java:45) [switchyard-bus-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:118) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:80) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.TryProcessor.process(TryProcessor.java:109) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.TryProcessor.process(TryProcessor.java:81) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91) [camel-core-2.12.2.jar:2.12.2]
        at org.switchyard.bus.camel.audit.FaultProcessor.process(FaultProcessor.java:45) [switchyard-bus-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:51) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.UnitOfWorkProducer.process(UnitOfWorkProducer.java:73) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:378) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:346) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:242) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache.sendExchange(ProducerCache.java:346) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache.send(ProducerCache.java:168) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.DefaultProducerTemplate.send(DefaultProducerTemplate.java:119) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.DefaultProducerTemplate.send(DefaultProducerTemplate.java:105) [camel-core-2.12.2.jar:2.12.2]
        at org.switchyard.bus.camel.ExchangeDispatcher.dispatch(ExchangeDispatcher.java:87) [switchyard-bus-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.bus.camel.CamelExchange.sendInternal(CamelExchange.java:238) [switchyard-bus-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.bus.camel.CamelExchange.send(CamelExchange.java:175) [switchyard-bus-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.component.bean.ClientProxyBean$ClientProxyInvocationHandler.invoke(ClientProxyBean.java:309) [switchyard-component-bean-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at com.sun.proxy.$Proxy25.greet(Unknown Source)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) [rt.jar:1.7.0_60]
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) [rt.jar:1.7.0_60]
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) [rt.jar:1.7.0_60]
        at java.lang.reflect.Method.invoke(Method.java:606) [rt.jar:1.7.0_60]
        at org.jboss.weld.bean.proxy.AbstractBeanInstance.invoke(AbstractBeanInstance.java:45) [weld-core-1.1.19.Final-redhat-1.jar:1.1.19.Final-redhat-1]
        at org.jboss.weld.bean.proxy.ProxyMethodHandler.invoke(ProxyMethodHandler.java:105) [weld-core-1.1.19.Final-redhat-1.jar:1.1.19.Final-redhat-1]
        at org.jboss.weld.proxies.GreetingService$1366014918$Proxy$_$$_WeldClientProxy.greet(GreetingService$1366014918$Proxy$_$$_WeldClientProxy.java) [weld-core-1.1.19.Final-redhat-1.jar:]
        at org.switchyard.quickstarts.camel.mqtt.binding.GreetingServiceBean.greet(GreetingServiceBean.java:42) [switchyard-camel-mqtt-binding-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) [rt.jar:1.7.0_60]
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) [rt.jar:1.7.0_60]
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) [rt.jar:1.7.0_60]
        at java.lang.reflect.Method.invoke(Method.java:606) [rt.jar:1.7.0_60]
        at org.switchyard.component.bean.ServiceProxyHandler.handle(ServiceProxyHandler.java:163) [switchyard-component-bean-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.component.bean.ServiceProxyHandler.handleMessage(ServiceProxyHandler.java:94) [switchyard-component-bean-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.handlers.ProviderHandler$1.run(ProviderHandler.java:60) [switchyard-runtime-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.handlers.ProviderHandler$1.run(ProviderHandler.java:58) [switchyard-runtime-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at java.security.AccessController.doPrivileged(Native Method) [rt.jar:1.7.0_60]
        at javax.security.auth.Subject.doAsPrivileged(Subject.java:536) [rt.jar:1.7.0_60]
        at org.switchyard.security.provider.DefaultSecurityProvider.runAs(DefaultSecurityProvider.java:169) [switchyard-security-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.handlers.ProviderHandler.handleMessage(ProviderHandler.java:65) [switchyard-runtime-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.bus.camel.processors.HandlerProcessor.process(HandlerProcessor.java:61) [switchyard-bus-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.apache.camel.processor.DelegateSyncProcessor.process(DelegateSyncProcessor.java:63) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91) [camel-core-2.12.2.jar:2.12.2]
        at org.switchyard.bus.camel.audit.FaultProcessor.process(FaultProcessor.java:45) [switchyard-bus-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:118) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:80) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.TryProcessor.process(TryProcessor.java:109) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.TryProcessor.process(TryProcessor.java:81) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91) [camel-core-2.12.2.jar:2.12.2]
        at org.switchyard.bus.camel.audit.FaultProcessor.process(FaultProcessor.java:45) [switchyard-bus-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:51) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.UnitOfWorkProducer.process(UnitOfWorkProducer.java:73) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:378) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:346) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:242) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache.sendExchange(ProducerCache.java:346) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache.send(ProducerCache.java:168) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.DefaultProducerTemplate.send(DefaultProducerTemplate.java:119) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.DefaultProducerTemplate.send(DefaultProducerTemplate.java:105) [camel-core-2.12.2.jar:2.12.2]
        at org.switchyard.bus.camel.ExchangeDispatcher.dispatch(ExchangeDispatcher.java:87) [switchyard-bus-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.bus.camel.CamelExchange.sendInternal(CamelExchange.java:238) [switchyard-bus-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.bus.camel.CamelExchange.send(CamelExchange.java:175) [switchyard-bus-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.switchyard.component.camel.switchyard.SwitchYardProducer.process(SwitchYardProducer.java:110) [switchyard-component-camel-switchyard-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:110) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:398) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:118) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:80) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:105) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:87) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.component.mqtt.MQTTConsumer.processExchange(MQTTConsumer.java:46) [camel-mqtt-2.12.2.jar:2.12.2]
        at org.apache.camel.component.mqtt.MQTTEndpoint$1.onPublish(MQTTEndpoint.java:90) [camel-mqtt-2.12.2.jar:2.12.2]
        at org.fusesource.mqtt.client.CallbackConnection.toReceiver(CallbackConnection.java:815) [mqtt-client-1.6.jar:1.6]
        at org.fusesource.mqtt.client.CallbackConnection.processFrame(CallbackConnection.java:732) [mqtt-client-1.6.jar:1.6]
        at org.fusesource.mqtt.client.CallbackConnection.access$1500(CallbackConnection.java:51) [mqtt-client-1.6.jar:1.6]
        at org.fusesource.mqtt.client.CallbackConnection$6.onTransportCommand(CallbackConnection.java:392) [mqtt-client-1.6.jar:1.6]
        at org.fusesource.hawtdispatch.transport.TcpTransport.drainInbound(TcpTransport.java:664) [hawtdispatch-transport-1.18.jar:1.18]
        at org.fusesource.hawtdispatch.transport.TcpTransport$6.run(TcpTransport.java:543) [hawtdispatch-transport-1.18.jar:1.18]
        at org.fusesource.hawtdispatch.internal.NioDispatchSource$3.run(NioDispatchSource.java:209) [hawtdispatch-1.18.jar:1.18]
        at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100) [hawtdispatch-1.18.jar:1.18]
        at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77) [hawtdispatch-1.18.jar:1.18]
Caused by: org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchange[Message: Hello there SpongeBob :-) ]
        at org.apache.camel.util.ObjectHelper.wrapCamelExecutionException(ObjectHelper.java:1368) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.DefaultExchange.setException(DefaultExchange.java:283) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:381) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:346) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:242) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache.sendExchange(ProducerCache.java:346) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache.send(ProducerCache.java:184) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.DefaultProducerTemplate.send(DefaultProducerTemplate.java:124) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.DefaultProducerTemplate.send(DefaultProducerTemplate.java:110) [camel-core-2.12.2.jar:2.12.2]
        at org.switchyard.component.camel.common.handler.OutboundHandler.handleInOnly(OutboundHandler.java:157) [switchyard-component-common-camel-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
        ... 110 more
Caused by: java.lang.AssertionError: Dispatch queue &apos;mqtt client&apos; was not executing, (currently executing: &apos;mqtt client&apos;)
        at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.assertExecuting(SerialDispatchQueue.java:145) [hawtdispatch-1.18.jar:1.18]
        at org.fusesource.mqtt.client.CallbackConnection.publish(CallbackConnection.java:585) [mqtt-client-1.6.jar:1.6]
        at org.fusesource.mqtt.client.CallbackConnection.publish(CallbackConnection.java:581) [mqtt-client-1.6.jar:1.6]
        at org.apache.camel.component.mqtt.MQTTEndpoint.publish(MQTTEndpoint.java:160) [camel-mqtt-2.12.2.jar:2.12.2]
        at org.apache.camel.component.mqtt.MQTTProducer.process(MQTTProducer.java:58) [camel-mqtt-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.processor.UnitOfWorkProducer.process(UnitOfWorkProducer.java:73) [camel-core-2.12.2.jar:2.12.2]
        at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:378) [camel-core-2.12.2.jar:2.12.2]
        ... 117 more