Fixed unsubscribe messages reducing counters when not subscribed

FraunhoferIOSB · Aug 8, 2024 · 06a2629 · 06a2629
1 parent 9de92c9
commit 06a2629
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 3 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -7,6 +7,7 @@
 * Fixed #1948: Sanitise user input in error output.
 * Fixed MultiDatastream not picking up ID type of Thing and Sensor.
 * Fixed Tomcat Docker images already having UID/GID 1000, FROST now uses 1001.
+* Fixed unsubscribe messages reducing counters when not subscribed.
 
 
 ## Release version 2.3.2

diff --git a/...src/main/java/de/fraunhofer/iosb/ilt/frostserver/mqtt/subscription/SubscriptionEvent.java b/...src/main/java/de/fraunhofer/iosb/ilt/frostserver/mqtt/subscription/SubscriptionEvent.java
@@ -37,4 +37,9 @@ public void setTopic(String topic) {
         this.topic = topic;
     }
 
+    @Override
+    public String toString() {
+        return getTopic();
+    }
+
 }
diff --git a/...te/src/main/java/de/fraunhofer/iosb/ilt/frostserver/mqtt/moquette/MoquetteMqttServer.java b/...te/src/main/java/de/fraunhofer/iosb/ilt/frostserver/mqtt/moquette/MoquetteMqttServer.java
@@ -288,7 +288,7 @@ public void onSubscribe(InterceptSubscribeMessage msg) {
             final String topicFilter = msg.getTopicFilter();
             LOGGER.trace("      Client {} subscribed to {}", clientId, topicFilter);
             clientSubscriptions
-                    .getOrDefault(clientId, new ArrayList<>())
+                    .computeIfAbsent(clientId, t -> new ArrayList<>())
                     .add(topicFilter);
             fireSubscribe(new SubscriptionEvent(topicFilter));
         }
@@ -301,9 +301,11 @@ public void onUnsubscribe(InterceptUnsubscribeMessage msg) {
             }
             final String topicFilter = msg.getTopicFilter();
             LOGGER.trace("      Client {} unsubscribed from {}", clientId, topicFilter);
-            clientSubscriptions.getOrDefault(clientId, new ArrayList<>())
+            boolean removed = clientSubscriptions.getOrDefault(clientId, new ArrayList<>())
                     .remove(topicFilter);
-            fireUnsubscribe(new SubscriptionEvent(topicFilter));
+            if (removed) {
+                fireUnsubscribe(new SubscriptionEvent(topicFilter));
+            }
         }
 
         @Override