More diagnostics (#271, #290)

home-climate-control · Oct 9, 2023 · 9bc34aa · 9bc34aa
1 parent e08b5f4
commit 9bc34aa
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/dz3r-mqtt/src/main/java/net/sf/dz3r/device/mqtt/v1/AbstractMqttAdapter.java b/dz3r-mqtt/src/main/java/net/sf/dz3r/device/mqtt/v1/AbstractMqttAdapter.java
@@ -212,7 +212,12 @@ private Flux<MqttSignal> createFlux(String topic, boolean includeSubtopics) {
             });
         });
 
-        var result = flux.publish().autoConnect();
+        var result = flux
+                .doOnNext(s -> logger.trace("{}: receive: {}", getAddress(), s))
+                .doOnError(t -> logger.error("{}: errored out", getAddress(), t))
+                .doOnComplete(() -> logger.debug("{}: completed", getAddress()))
+                .publish()
+                .autoConnect();
 
         var topicFilter = topic + (includeSubtopics ? "/#" : "");