wip

1 files changed, 7 insertions, 1 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 f5bfb8a..c77bb7d 100644
--- a/calamus-engine/src/main/java/io/trygvis/engine/Main.java
+++ b/calamus-engine/src/main/java/io/trygvis/engine/Main.java
@@ -11,8 +11,14 @@ public class Main {
 
         StatefulKnowledgeSession session = calamus.getSession();
 
+//        EntityManager entityManager = calamus.getEntityManagerFactory().createEntityManager();
+//        EntityTransaction transaction = entityManager.getTransaction();
+//        transaction.begin();
+//        entityManager.createQuery("FROM Process");
+//        transaction.commit();
+
         try (MqClient buildResultClient = new MqClient(brokerUrl, "jenkins.build-result", new JenkinsBuildResultMessageListener(session));
-             MqClient newDeployClient = new MqClient(brokerUrl, "nexus.new-artifact", new NexusNewArtifactMessageListener(session))) {
+             MqClient newDeployClient = new MqClient(brokerUrl, "nexus.new-artifact", new NexusNewArtifactMessageListener(calamus.getEntityManagerFactory(), session))) {
 
             while (true) {
                 Thread.sleep(1000);