Stefan Hudelmaier created CAMEL-5670: ----------------------------------------
Summary: Nullpointer Exception when disconnected from broker Key: CAMEL-5670 URL: https://issues.apache.org/jira/browse/CAMEL-5670 Project: Camel Issue Type: Bug Components: camel-mqtt Affects Versions: 2.10.1, 2.9.3 Reporter: Stefan Hudelmaier Priority: Minor Hi, from time to time, we get the following exception when producing messages via camel-mqtt: bq. Caused by: java.lang.NullPointerException at org.fusesource.mqtt.client.CallbackConnection.publish(CallbackConnection.java:551) at org.fusesource.mqtt.client.CallbackConnection.publish(CallbackConnection.java:545) at org.apache.camel.component.mqtt.MQTTEndpoint.publish(MQTTEndpoint.java:166) at org.apache.camel.component.mqtt.MQTTProducer.doProcess(MQTTProducer.java:66) at org.apache.camel.component.mqtt.MQTTProducer.process(MQTTProducer.java:38) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73) [...] >From looking at the source of both camel-mqtt and the fusesource mqtt client, >it looks like that this is caused by the mqtt-client being disconnected and >trying to invoke the onFailure method on the callback: {code:title=CallbackConnection.java} public void publish(UTF8Buffer topic, Buffer payload, QoS qos, boolean retain, Callback<Void> cb) { queue.assertExecuting(); if( disconnected ) { cb.onFailure(createDisconnectedError()); return; } PUBLISH command = new PUBLISH().qos(qos).retain(retain); command.topicName(topic).payload(payload); send(command, cb); } {code} camel-mqtt passes in null for the callback though. Wouldn't it be better if a more fitting exception were thrown, or if camel passed in a Callback in order to receive the onFailure event when disconnected from the broker? -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira