Uploaded image for project: 'SwitchYard'
  1. SwitchYard
  2. SWITCHYARD-2221

camel-mqtt producer fails to publish with AssertionError in a unit test

    Details

    • Type: Bug
    • Status: Resolved (View Workflow)
    • Priority: Major
    • Resolution: Done
    • Affects Version/s: None
    • Fix Version/s: 2.1.0
    • Component/s: None
    • Labels:

      Description

      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.

      [0m[31m18:06:27,482 ERROR [org.switchyard.bus.camel.DefaultErrorListener] (hawtdispatch-DEFAULT-2) 
      ------- Begin Message Trace -------
      Consumer -> {urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}GreetingService/StoreReference
      Provider -> {urn:switchyard-quickstart:camel-mqtt-binding:0.1.0}StoreReference
      Operation -> greet
      MEP -> IN_ONLY
      Phase -> IN
      State -> OK
      Exchange Context -> 
          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 -> 
          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 'mqtt client' was not executing, (currently executing: 'mqtt client'): 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 'mqtt client' was not executing, (currently executing: 'mqtt client')
              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
      

      You can run the MQTTProducerTest with commenting out this line and run mvn clean package
      https://github.com/apache/camel/blob/camel-2.12.2/components/camel-mqtt/pom.xml#L84

        Gliffy Diagrams

          Attachments

            Issue Links

              Activity

                People

                • Assignee:
                  igarashitm tomohisa igarashi
                  Reporter:
                  igarashitm tomohisa igarashi
                • Votes:
                  0 Vote for this issue
                  Watchers:
                  1 Start watching this issue

                  Dates

                  • Created:
                    Updated:
                    Resolved: