Conductor support (#30)

Author: devhawk

build.gradle.kts

@@ -54,6 +54,7 @@ dependencies {
     testImplementation("io.rest-assured:xml-path:5.4.0")
     testImplementation(platform("org.junit:junit-bom:5.10.0"))
     testImplementation("org.junit.jupiter:junit-jupiter")
+    testImplementation("org.java-websocket:Java-WebSocket:1.5.6")
 }
 
 tasks.test {

src/main/java/dev/dbos/transact/DBOS.java

@@ -1,5 +1,6 @@
 package dev.dbos.transact;
 
+import dev.dbos.transact.conductor.Conductor;
 import dev.dbos.transact.config.DBOSConfig;
 import dev.dbos.transact.database.SystemDatabase;
 import dev.dbos.transact.execution.DBOSExecutor;
@@ -38,6 +39,7 @@ public class DBOS {
     private final QueueService queueService;
     private final SchedulerService schedulerService;
     private NotificationService notificationService;
+    private Conductor conductor;
     private HttpServer httpServer;
     private RecoveryService recoveryService;
 
@@ -222,6 +224,12 @@ public void launch() {
             notificationService.start();
         }
 
+        String conductorKey = config.getConductorKey();
+        if (conductorKey != null) {
+            conductor = new Conductor.Builder(systemDatabase, dbosExecutor, conductorKey).build();
+            conductor.start();
+        }
+
         if (config.isHttp()) {
             httpServer = HttpServer.getInstance(config.getHttpPort(),
                     new AdminController(systemDatabase, dbosExecutor));
@@ -263,6 +271,10 @@ public void shutdown() {
                 notificationService.stop();
             }
 
+            if (conductor != null) {
+                conductor.stop();
+            }
+
             if (config.isHttp()) {
                 httpServer.stop();
             }