[CAMEL-10695] camel-mqtt: TimeoutException thrown on MQTTEndpoint stop

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 2.18.2, 2.19.0
• Component/s: camel-mqtt
• Estimated Complexity: Unknown
• Assignee: Luca Burgazzoli
• Reporter: Luca Burgazzoli
• Created: 11/Jan/17 13:52
• Updated: 11/Jan/17 15:45
• Resolved: 11/Jan/17 15:45

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)