[camel-karavan] branch main updated: Headless chaos for #817

[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


The following commit(s) were added to refs/heads/main by this push:
     new e9c4ffe8 Headless chaos for #817
e9c4ffe8 is described below

commit e9c4ffe812912516c9606061fba74c03135f6093
Author: Marat Gubaidullin <ma...@talismancloud.io>
AuthorDate: Fri Sep 1 15:49:34 2023 -0400

    Headless chaos for #817
---
 .../org/apache/camel/karavan/service/GiteaService.java   |  1 -
 .../org/apache/camel/karavan/service/KaravanService.java |  1 -
 .../org/apache/camel/karavan/headless/EventService.java  |  1 -
 .../apache/camel/karavan/headless/HeadlessService.java   | 16 ++++++++++++++--
 4 files changed, 14 insertions(+), 5 deletions(-)

diff --git 
a/karavan-web/karavan-app/src/main/java/org/apache/camel/karavan/service/GiteaService.java
 
b/karavan-web/karavan-app/src/main/java/org/apache/camel/karavan/service/GiteaService.java
index 2cd4c6ce..1930be7c 100644
--- 
a/karavan-web/karavan-app/src/main/java/org/apache/camel/karavan/service/GiteaService.java
+++ 
b/karavan-web/karavan-app/src/main/java/org/apache/camel/karavan/service/GiteaService.java
@@ -29,7 +29,6 @@ import org.jboss.logging.Logger;
 
 import java.util.List;
 import java.util.Map;
-import java.util.UUID;
 
 @ApplicationScoped
 public class GiteaService {
diff --git 
a/karavan-web/karavan-app/src/main/java/org/apache/camel/karavan/service/KaravanService.java
 
b/karavan-web/karavan-app/src/main/java/org/apache/camel/karavan/service/KaravanService.java
index ae1adc80..7a811548 100644
--- 
a/karavan-web/karavan-app/src/main/java/org/apache/camel/karavan/service/KaravanService.java
+++ 
b/karavan-web/karavan-app/src/main/java/org/apache/camel/karavan/service/KaravanService.java
@@ -35,7 +35,6 @@ import jakarta.enterprise.event.Observes;
 import jakarta.inject.Inject;
 import java.io.IOException;
 
-
 @Singleton
 public class KaravanService {
 
diff --git 
a/karavan-web/karavan-headless/src/main/java/org/apache/camel/karavan/headless/EventService.java
 
b/karavan-web/karavan-headless/src/main/java/org/apache/camel/karavan/headless/EventService.java
index 533a0953..116a00d8 100644
--- 
a/karavan-web/karavan-headless/src/main/java/org/apache/camel/karavan/headless/EventService.java
+++ 
b/karavan-web/karavan-headless/src/main/java/org/apache/camel/karavan/headless/EventService.java
@@ -22,7 +22,6 @@ import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
 import org.apache.camel.karavan.infinispan.InfinispanService;
 
-
 @ApplicationScoped
 public class EventService {
 
diff --git 
a/karavan-web/karavan-headless/src/main/java/org/apache/camel/karavan/headless/HeadlessService.java
 
b/karavan-web/karavan-headless/src/main/java/org/apache/camel/karavan/headless/HeadlessService.java
index e822f800..d63ac25b 100644
--- 
a/karavan-web/karavan-headless/src/main/java/org/apache/camel/karavan/headless/HeadlessService.java
+++ 
b/karavan-web/karavan-headless/src/main/java/org/apache/camel/karavan/headless/HeadlessService.java
@@ -18,6 +18,8 @@ package org.apache.camel.karavan.headless;
 
 import io.quarkus.runtime.StartupEvent;
 import io.quarkus.scheduler.Scheduled;
+import io.quarkus.vertx.ConsumeEvent;
+import io.vertx.core.eventbus.EventBus;
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.enterprise.event.Observes;
 import jakarta.inject.Inject;
@@ -35,9 +37,19 @@ public class HeadlessService {
     @Inject
     CamelService camelService;
 
-    void onStart(@Observes StartupEvent ev) {
+    @Inject
+    EventBus eventBus;
+
+    private static final String START_SERVICES = "START_SERVICES";
+
+    void onStart(@Observes StartupEvent ev) throws Exception {
+        eventBus.publish(START_SERVICES, null);
+    }
+
+    @ConsumeEvent(value = START_SERVICES, blocking = true)
+    void startServices(String data) throws Exception {
         LOGGER.info("Starting Headless Karavan");
-        infinispanService.start(true);
+        infinispanService.tryStart(true);
     }
 
     @Scheduled(every = "{karavan.camel.status.interval}", concurrentExecution 
= Scheduled.ConcurrentExecution.SKIP)