add check for timeout isZero()

inspectIT · Dec 13, 2024 · 1123a7a · 1123a7a
1 parent d948839
commit 1123a7a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...it-ocelot-core/src/main/java/rocks/inspectit/ocelot/core/command/AgentCommandService.java b/...it-ocelot-core/src/main/java/rocks/inspectit/ocelot/core/command/AgentCommandService.java
@@ -123,7 +123,7 @@ private void startScheduledHandler() {
         handlerFuture = executor.scheduleWithFixedDelay(this,
                 pollingInterval.toMillis(), pollingInterval.toMillis(), TimeUnit.MILLISECONDS);
         // Setup timeout for fetching a command
-        if (pollingTimeout != null)
+        if (pollingTimeout != null && !pollingTimeout.isZero())
             timeoutExecutor.scheduleCancelling(handlerFuture, "agentcommand", this::startScheduledHandler, pollingTimeout);
     }
 

diff --git a/...java/rocks/inspectit/ocelot/core/config/propertysources/http/HttpConfigurationPoller.java b/...java/rocks/inspectit/ocelot/core/config/propertysources/http/HttpConfigurationPoller.java
@@ -114,7 +114,7 @@ private void startScheduledPolling() {
         pollerFuture = executor.scheduleWithFixedDelay(this,
                 pollingInterval.toMillis(), pollingInterval.toMillis(), TimeUnit.MILLISECONDS);
         // Setup timeout for fetching the configuration
-        if (pollingTimeout != null)
+        if (pollingTimeout != null && !pollingTimeout.isZero())
             timeoutExecutor.scheduleCancelling(pollerFuture, "http.config", this::startScheduledPolling, pollingTimeout);
     }