1 files changed, 5 insertions, 0 deletions
diff --git a/src/main/java/io/trygvis/queue/QueueSystem.java b/src/main/java/io/trygvis/queue/QueueSystem.java
index 42c8fd8..3b0c018 100644
--- a/src/main/java/io/trygvis/queue/QueueSystem.java
+++ b/src/main/java/io/trygvis/queue/QueueSystem.java
@@ -1,5 +1,6 @@
 package io.trygvis.queue;
 
+import io.trygvis.async.JdbcAsyncService;
 import io.trygvis.async.SqlEffect;
 import io.trygvis.async.SqlEffectExecutor;
 import org.slf4j.Logger;
@@ -55,4 +56,8 @@ public class QueueSystem {
     public TaskDao createTaskDao(Connection c) {
         return new TaskDao(c);
     }
+
+    public JdbcAsyncService createAsyncService() {
+        return new JdbcAsyncService(this);
+    }
 }