Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
-
Unknown
Description
If MQTTEndpoint's doStop method is execuded but a the MQTT connection is not established, the endpoint throws a TimeoutException like:
Caused by: java.util.concurrent.TimeoutException at org.fusesource.mqtt.client.Promise.await(Promise.java:83) at org.apache.camel.component.mqtt.MQTTEndpoint.doStop(MQTTEndpoint.java:300) at org.apache.camel.support.ServiceSupport.stop(ServiceSupport.java:102) at org.apache.camel.util.ServiceHelper.stopService(ServiceHelper.java:142) at org.apache.camel.impl.DefaultCamelContext.stopServices(DefaultCamelContext.java:3361) at org.apache.camel.impl.DefaultCamelContext.addEndpoint(DefaultCamelContext.java:522) at org.apache.camel.component.ref.RefEndpoint.doStart(RefEndpoint.java:81)