diff --git a/dz3r-bootstrap/src/main/java/net/sf/dz3r/runtime/config/connector/ConnectorConfigurationParser.java b/dz3r-bootstrap/src/main/java/net/sf/dz3r/runtime/config/connector/ConnectorConfigurationParser.java index 997a41741..22915c08c 100644 --- a/dz3r-bootstrap/src/main/java/net/sf/dz3r/runtime/config/connector/ConnectorConfigurationParser.java +++ b/dz3r-bootstrap/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 parse(Set source) { // Prevent multiple subscriptions .publish() - .autoConnect(); + .autoConnect() + .cache(Duration.ofSeconds(30)); // Start right away flux.subscribe(e -> logger.debug("subscription: {}", e));