(camel-karavan) 05/07: Fix #1377

[marat]

This is an automated email from the ASF dual-hosted git repository.

marat pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-karavan.git

commit 9258dd3ffc785c6199b76fb54f88808189d66c26
Author: Marat Gubaidullin <ma...@talismancloud.io>
AuthorDate: Sun Aug 25 12:43:37 2024 -0400

    Fix #1377
---
 .../main/java/org/apache/camel/karavan/api/LogWatchResource.java  | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/karavan-app/src/main/java/org/apache/camel/karavan/api/LogWatchResource.java 
b/karavan-app/src/main/java/org/apache/camel/karavan/api/LogWatchResource.java
index 3bb7cab9..3dd0bac3 100644
--- 
a/karavan-app/src/main/java/org/apache/camel/karavan/api/LogWatchResource.java
+++ 
b/karavan-app/src/main/java/org/apache/camel/karavan/api/LogWatchResource.java
@@ -34,6 +34,7 @@ import org.apache.camel.karavan.docker.DockerLogCallback;
 import org.apache.camel.karavan.docker.DockerService;
 import org.apache.camel.karavan.kubernetes.KubernetesService;
 import org.apache.camel.karavan.service.ConfigService;
+import org.apache.camel.karavan.service.NotificationService;
 import org.eclipse.microprofile.context.ManagedExecutor;
 import org.jboss.logging.Logger;
 
@@ -43,7 +44,7 @@ import java.io.InputStreamReader;
 import java.util.concurrent.ConcurrentHashMap;
 
 @Path("/ui/logwatch")
-public class LogWatchResource extends AbstractSseResource {
+public class LogWatchResource {
 
     private static final Logger LOGGER = 
Logger.getLogger(LogWatchResource.class.getName());
     private static final String SERVICE_NAME = "LOGWATCH";
@@ -55,6 +56,9 @@ public class LogWatchResource extends AbstractSseResource {
     @Inject
     DockerService dockerService;
 
+    @Inject
+    NotificationService notificationService;
+
     @Inject
     @ManagedExecutorConfig()
     @NamedInstance("logExecutor")
@@ -68,7 +72,7 @@ public class LogWatchResource extends AbstractSseResource {
                               @PathParam("username") String username,
                               @Context SseEventSink eventSink,
                               @Context Sse sse) {
-        sinkCleanup(SERVICE_NAME + ":" + type + ":" + name, username, 
eventSink);
+        notificationService.sinkCleanup(SERVICE_NAME + ":" + type + ":" + 
name, username, eventSink);
         managedExecutor.execute(() -> {
             LOGGER.info("LogWatch for " + name + " starting... ");
             if (ConfigService.inKubernetes()) {