remove timeout from default config

inspectit-ocelot-config/src/main/resources/rocks/inspectit/ocelot/config/default/basics.yml

@@ -138,8 +138,6 @@ inspectit:
     polling-interval: 15s
     # the time to keep an HTTP connection alive
     time-to-live: 4m
-    # the maximum time to run one agent command polling task - set to 0s to disable
-    task-timeout: 32m
     # how long the agent will stay in the live mode, before falling back to the normal mode
     live-mode-duration: 2m
     retry:

inspectit-ocelot-config/src/main/resources/rocks/inspectit/ocelot/config/default/config-sources.yml

@@ -27,8 +27,6 @@ inspectit:
       enabled: true
       # the frequency of polling the http endpoint to check for configuration changes
       frequency: 30s
-      # the maximum time to run one http polling task - set to 0s to disable timeout
-      task-timeout: 64m
       # the following attributes will be sent as http query parameters when fetching the configuration
       attributes:
         service: ${inspectit.service-name}

inspectit-ocelot-core/src/main/java/rocks/inspectit/ocelot/core/command/AgentCommandService.java

@@ -125,7 +125,7 @@ private void startScheduledHandler() {
         handlerFuture = executor.scheduleWithFixedDelay(this,
                 pollingInterval.toMillis(), pollingInterval.toMillis(), TimeUnit.MILLISECONDS);
         // Setup timeout for fetching a command
-        if (!pollingTimeout.isZero())
+        if (pollingTimeout != null)
             timeoutExecutor.scheduleCancelling(handlerFuture, "agentcommand", this::startScheduledHandler, pollingTimeout);
     }
 

inspectit-ocelot-core/src/main/java/rocks/inspectit/ocelot/core/config/propertysources/http/HttpConfigurationPoller.java

@@ -115,7 +115,7 @@ private void startScheduledPolling() {
         pollerFuture = executor.scheduleWithFixedDelay(this,
                 pollingInterval.toMillis(), pollingInterval.toMillis(), TimeUnit.MILLISECONDS);
         // Setup timeout for fetching the configuration
-        if (!pollingTimeout.isZero())
+        if (pollingTimeout != null)
             timeoutExecutor.scheduleCancelling(pollerFuture, "http.config", this::startScheduledPolling, pollingTimeout);
     }
 

inspectit-ocelot-core/src/test/java/rocks/inspectit/ocelot/core/command/AgentCommandServiceTest.java

@@ -188,9 +188,7 @@ void shouldNotCancelFutureWhenNoTimeout() throws MalformedURLException {
 
         @Test
         void shouldNotCancelFutureWhenTimeoutIsZero() throws MalformedURLException {
-            Duration timeout = Duration.ofMillis(0);
             when(configuration.getAgentCommands().getPollingInterval()).thenReturn(Duration.ofMillis(500));
-            when(configuration.getAgentCommands().getTaskTimeout()).thenReturn(timeout);
             when(configuration.getAgentCommands().getUrl()).thenReturn(new URL("http://example.org"));
             ScheduledFuture future = mock(ScheduledFuture.class);
             when(executor.scheduleWithFixedDelay(any(Runnable.class), anyLong(), anyLong(), any(TimeUnit.class))).thenReturn(future);

inspectit-ocelot-core/src/test/java/rocks/inspectit/ocelot/core/config/propertysources/http/HttpConfigurationPollerTest.java

@@ -167,12 +167,10 @@ void shouldNotCancelFutureWhenNoTimeout() {
 
         @Test
         void shouldNotCancelFutureWhenTimeoutIsZero() {
-            Duration timeout = Duration.ofMillis(0);
             InspectitConfig configuration = new InspectitConfig();
             configuration.setConfig(new ConfigSettings());
             configuration.getConfig().setHttp(new HttpConfigSettings());
             configuration.getConfig().getHttp().setFrequency(Duration.ofMillis(500));
-            configuration.getConfig().getHttp().setTaskTimeout(timeout);
             ScheduledFuture future = Mockito.mock(ScheduledFuture.class);
             when(executor.scheduleWithFixedDelay(any(Runnable.class), anyLong(), anyLong(), any(TimeUnit.class))).thenReturn(future);