1 files changed, 14 insertions, 5 deletions
diff --git a/calamus-engine/src/main/java/io/trygvis/engine/Main.java b/calamus-engine/src/main/java/io/trygvis/engine/Main.java
index bc322e8..f5bfb8a 100644
--- a/calamus-engine/src/main/java/io/trygvis/engine/Main.java
+++ b/calamus-engine/src/main/java/io/trygvis/engine/Main.java
@@ -1,13 +1,22 @@
 package io.trygvis.engine;
 
-import static io.trygvis.engine.CalamusJbpm.CalamusProcess.DEPLOY;
+import org.kie.internal.runtime.StatefulKnowledgeSession;
 
 public class Main {
-    public static void main(String[] args) {
-        CalamusJbpm jbpm = new CalamusJbpm();
+    public static void main(String[] args) throws Exception {
 
-        MqClient mqClient = new MqClient(jbpm.getSession(), "tcp://localhost:61616");
+        CalamusJbpm calamus = new CalamusJbpm();
 
-        jbpm.startProcess(DEPLOY);
+        String brokerUrl = "tcp://localhost:61616";
+
+        StatefulKnowledgeSession session = calamus.getSession();
+
+        try (MqClient buildResultClient = new MqClient(brokerUrl, "jenkins.build-result", new JenkinsBuildResultMessageListener(session));
+             MqClient newDeployClient = new MqClient(brokerUrl, "nexus.new-artifact", new NexusNewArtifactMessageListener(session))) {
+
+            while (true) {
+                Thread.sleep(1000);
+            }
+        }
     }
 }