aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/io/trygvis/queue/QueueSystem.java
diff options
context:
space:
mode:
authorTrygve Laugstøl <trygvis@inamo.no>2013-06-12 22:55:18 +0200
committerTrygve Laugstøl <trygvis@inamo.no>2013-06-12 22:55:18 +0200
commit54d7b2ce520e57cc0ffb9582546b80a32fa00682 (patch)
treead68043a4f05780c6b87a494f7498297ff978953 /src/main/java/io/trygvis/queue/QueueSystem.java
parent4b0bab9e722cf77ca0049c54515e8c93acefa355 (diff)
downloadquartz-based-queue-54d7b2ce520e57cc0ffb9582546b80a32fa00682.tar.gz
quartz-based-queue-54d7b2ce520e57cc0ffb9582546b80a32fa00682.tar.bz2
quartz-based-queue-54d7b2ce520e57cc0ffb9582546b80a32fa00682.tar.xz
quartz-based-queue-54d7b2ce520e57cc0ffb9582546b80a32fa00682.zip
wip
Diffstat (limited to 'src/main/java/io/trygvis/queue/QueueSystem.java')
-rw-r--r--src/main/java/io/trygvis/queue/QueueSystem.java5
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);
+ }
}