From bf9b68d08b082c025a019a5581ae4d3d86b03ff4 Mon Sep 17 00:00:00 2001 From: Nayir Michael Date: Wed, 17 May 2023 14:55:42 +0200 Subject: [PATCH] Update MqttAsyncClient.java set topics for the token which can cause null pointer exception if not set --- .../java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java b/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java index ced752d8..5f10596c 100644 --- a/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java +++ b/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java @@ -1161,7 +1161,7 @@ private IMqttToken subscribeBase(MqttSubscription[] subscriptions, Object userCo token.setActionCallback(callback); token.setUserContext(userContext); // TODO - Somehow refactor this.... - // token.internalTok.setTopics(topicFilters); + token.internalTok.setTopics(topicFilters); // TODO - Build up MQTT Subscriptions properly here MqttSubscribe register = new MqttSubscribe(subscriptions, subscriptionProperties);