Bugfix for race condition from rev. 066185a (how permanent?) (#47, #271)

home-climate-control · Oct 7, 2023 · 564a926 · 564a926
1 parent a0215c6
commit 564a926
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...trap/src/main/java/net/sf/dz3r/runtime/config/connector/ConnectorConfigurationParser.java b/...trap/src/main/java/net/sf/dz3r/runtime/config/connector/ConnectorConfigurationParser.java
@@ -20,6 +20,7 @@
 import java.io.IOException;
 import java.net.MalformedURLException;
 import java.net.URL;
+import java.time.Duration;
 import java.util.Map;
 import java.util.Optional;
 import java.util.Set;
@@ -63,7 +64,8 @@ public Flux<Object> parse(Set<ConnectorConfig> source) {
 
                 // Prevent multiple subscriptions
                 .publish()
-                .autoConnect();
+                .autoConnect()
+                .cache(Duration.ofSeconds(30));
 
         // Start right away
         flux.subscribe(e -> logger.debug("subscription: {}", e));