demus/openhab-addons
1
0
Fork 0
mirror of https://github.com/openhab/openhab-addons.git synced 2025-01-25 14:55:55 +01:00
Code Issues Packages Projects Releases Wiki Activity

[mqtt] Only unsubscribe if we subscribed before (#9758)

Browse Source 
Fix for 9730

Signed-off-by: Jochen Klein <git@jochen.susca.de>
This commit is contained in:
Jochen Klein 2021-01-10 16:25:54 +01:00 committed by GitHub
parent 79b94e3e34
commit b6eea715fa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
bundles/org.openhab.binding.mqtt/src/main/java/org/openhab/binding/mqtt/discovery/TopicSubscribe.java
View File

@ -53,8 +53,9 @@ public class TopicSubscribe implements MqttMessageSubscriber {
@Override
public void processMessage(String topic, byte[] payload) {
final MqttBrokerConnection connection = this.connection;
if (connection == null)
if (connection == null) {
return;
}
if (payload.length > 0) {
topicDiscoveredListener.receivedMessage(thing, connection, topic, payload);
} else {
@ -80,7 +81,8 @@ public class TopicSubscribe implements MqttMessageSubscriber {
* @return Completes with true if successful. Exceptionally otherwise.
*/
public CompletableFuture<Boolean> stop() {
CompletableFuture<Boolean> stopFuture = connection == null ? CompletableFuture.completedFuture(true)
CompletableFuture<Boolean> stopFuture = connection == null || !isStarted
? CompletableFuture.completedFuture(true)
: connection.unsubscribe(topic, this);
isStarted = false;
return stopFuture;