diff --git a/mqtt-client-java1.4-uber/pom.xml b/mqtt-client-java1.4-uber/pom.xml index e2388e1..6582d83 100644 --- a/mqtt-client-java1.4-uber/pom.xml +++ b/mqtt-client-java1.4-uber/pom.xml @@ -25,13 +25,13 @@ org.fusesource.mqtt-client mqtt-client-project - 1.15-SNAPSHOT + 1.14.sofia org.fusesource.mqtt-client mqtt-client-java1.4-uber - 1.15-SNAPSHOT + 1.14.sofia ${project.artifactId} diff --git a/mqtt-client-website/pom.xml b/mqtt-client-website/pom.xml index 7588118..ba399f6 100644 --- a/mqtt-client-website/pom.xml +++ b/mqtt-client-website/pom.xml @@ -26,12 +26,12 @@ org.fusesource.mqtt-client mqtt-client-project - 1.15-SNAPSHOT + 1.14.sofia org.fusesource.mqtt-client mqtt-client-website - 1.15-SNAPSHOT + 1.14.sofia war ${project.artifactId} diff --git a/mqtt-client/pom.xml b/mqtt-client/pom.xml index b6f7d80..b93a47a 100755 --- a/mqtt-client/pom.xml +++ b/mqtt-client/pom.xml @@ -25,12 +25,12 @@ org.fusesource.mqtt-client mqtt-client-project - 1.15-SNAPSHOT + 1.14.sofia org.fusesource.mqtt-client mqtt-client - 1.15-SNAPSHOT + 1.14.sofia bundle ${project.artifactId} diff --git a/mqtt-client/src/main/java/org/fusesource/mqtt/client/CallbackConnection.java b/mqtt-client/src/main/java/org/fusesource/mqtt/client/CallbackConnection.java index 9aadb95..e2267ac 100644 --- a/mqtt-client/src/main/java/org/fusesource/mqtt/client/CallbackConnection.java +++ b/mqtt-client/src/main/java/org/fusesource/mqtt/client/CallbackConnection.java @@ -1,5 +1,6 @@ /** * Copyright (C) 2010-2012, FuseSource Corp. All rights reserved. + * Copyright (C) 2016, Indra Sistemas S.A. All rights reserved * * http://fusesource.com * @@ -634,15 +635,20 @@ public void kill(final Callback onComplete) { heartBeatMonitor.stop(); heartBeatMonitor = null; } - transport.stop(new Task() { - @Override - public void run() { - listener.onDisconnected(); - if (onComplete != null) { - onComplete.onSuccess(null); - } - } - }); + /* + * Fix: in some scenarios, a NullPointerException was raised when the connection was killed. + */ + if (transport!=null) { + transport.stop(new Task() { + @Override + public void run() { + listener.onDisconnected(); + if (onComplete != null) { + onComplete.onSuccess(null); + } + } + }); + } } public void publish(String topic, byte[] payload, QoS qos, boolean retain, Callback cb) { diff --git a/pom.xml b/pom.xml index 3aae50e..cd79cea 100644 --- a/pom.xml +++ b/pom.xml @@ -30,7 +30,7 @@ org.fusesource.mqtt-client mqtt-client-project - 1.15-SNAPSHOT + 1.14.sofia pom ${project.artifactId}