Scheduler fixes

Author: mgubaidullin

karavan-app/src/main/java/org/apache/camel/karavan/scheduler/CamelStatusScheduler.java

@@ -24,6 +24,7 @@
 import org.apache.camel.karavan.KaravanCache;
 import org.apache.camel.karavan.KaravanConstants;
 import org.apache.camel.karavan.model.CamelStatusRequest;
+import org.apache.camel.karavan.service.ConfigService;
 import org.eclipse.microprofile.config.inject.ConfigProperty;
 import org.jboss.logging.Logger;
 
@@ -51,14 +52,25 @@ public class CamelStatusScheduler {
     @Scheduled(every = "{karavan.camel.status.interval}", concurrentExecution = Scheduled.ConcurrentExecution.SKIP)
     public void collectCamelStatuses() {
         LOGGER.debug("Collect Camel Statuses");
-        karavanCache.getPodContainerStatuses(environment).stream()
-                .filter(cs -> Objects.equals(cs.getLabels().get(LABEL_KUBERNETES_RUNTIME), CAMEL_PREFIX))
-                .filter(cs -> Objects.equals(cs.getCamelRuntime(), KaravanConstants.CamelRuntime.CAMEL_MAIN.getValue()))
-                .forEach(cs -> {
-                    CamelStatusRequest csr = new CamelStatusRequest(cs.getProjectId(), cs.getContainerName());
-                    eventBus.publish(CMD_COLLECT_CAMEL_STATUS,
-                            JsonObject.mapFrom(Map.of("containerStatus", cs, "camelStatusRequest", csr))
-                    );
-                });
+        if (ConfigService.inKubernetes()) {
+            karavanCache.getPodContainerStatuses(environment).stream()
+                    .filter(cs -> Objects.equals(cs.getLabels().get(LABEL_KUBERNETES_RUNTIME), CAMEL_PREFIX))
+                    .filter(cs -> Objects.equals(cs.getCamelRuntime(), KaravanConstants.CamelRuntime.CAMEL_MAIN.getValue()))
+                    .forEach(cs -> {
+                        CamelStatusRequest csr = new CamelStatusRequest(cs.getProjectId(), cs.getContainerName());
+                        eventBus.publish(CMD_COLLECT_CAMEL_STATUS,
+                                JsonObject.mapFrom(Map.of("containerStatus", cs, "camelStatusRequest", csr))
+                        );
+                    });
+        } else {
+            karavanCache.getPodContainerStatuses(environment).stream()
+                    .filter(cs -> Objects.equals(cs.getCamelRuntime(), KaravanConstants.CamelRuntime.CAMEL_MAIN.getValue()))
+                    .forEach(cs -> {
+                        CamelStatusRequest csr = new CamelStatusRequest(cs.getProjectId(), cs.getContainerName());
+                        eventBus.publish(CMD_COLLECT_CAMEL_STATUS,
+                                JsonObject.mapFrom(Map.of("containerStatus", cs, "camelStatusRequest", csr))
+                        );
+                    });
+        }
     }
 }