diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-04 20:54:56 +0200 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-04 20:54:56 +0200 |
commit | 7465fdb9aa847d29dacc56adbe473f1c1ceb298e (patch) | |
tree | d04b5c859fc090a57355e7bc0e51a043cddc907b /src/test/java/io/trygvis/test/Main.java | |
parent | 1eeef021c65c85c24d62a0cc1ee4a746a601beb5 (diff) | |
download | quartz-based-queue-7465fdb9aa847d29dacc56adbe473f1c1ceb298e.tar.gz quartz-based-queue-7465fdb9aa847d29dacc56adbe473f1c1ceb298e.tar.bz2 quartz-based-queue-7465fdb9aa847d29dacc56adbe473f1c1ceb298e.tar.xz quartz-based-queue-7465fdb9aa847d29dacc56adbe473f1c1ceb298e.zip |
o Creating a QueueService on top of the DAOs.
Diffstat (limited to 'src/test/java/io/trygvis/test/Main.java')
-rwxr-xr-x | src/test/java/io/trygvis/test/Main.java | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/test/java/io/trygvis/test/Main.java b/src/test/java/io/trygvis/test/Main.java index d274101..43ee971 100755 --- a/src/test/java/io/trygvis/test/Main.java +++ b/src/test/java/io/trygvis/test/Main.java @@ -2,6 +2,7 @@ package io.trygvis.test; import io.trygvis.async.AsyncService; import io.trygvis.queue.Queue; +import io.trygvis.queue.QueueService; import io.trygvis.queue.Task; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -57,6 +58,9 @@ public class Main { private AsyncService asyncService; @Autowired + private QueueService queueService; + + @Autowired @Qualifier("createArticle") private AsyncService.AsyncCallable createArticleCallable; @@ -67,7 +71,9 @@ public class Main { public void run() throws Exception { log.info("Main.run"); - final Queue q = asyncService.registerQueue("create-article", 1, createArticleCallable); + final Queue q = null; // queueService.getQueue(c, "create-article", 1); + + asyncService.registerQueue(q, createArticleCallable); // log.info("queue registered: ref = {}", q); // asyncService.registerQueue("update-queue", 1, updateArticleCallable); |