aboutsummaryrefslogtreecommitdiff
path: root/src/test/java/io/trygvis/test/Main.java
diff options
context:
space:
mode:
authorTrygve Laugstøl <trygvis@inamo.no>2013-06-16 12:07:43 +0200
committerTrygve Laugstøl <trygvis@inamo.no>2013-06-16 12:07:43 +0200
commit1ec4fae12c5e5363591013e5a759590d913d6782 (patch)
treebac64a4e0e86a3227ca21591b8efc34aee6223da /src/test/java/io/trygvis/test/Main.java
parent54d7b2ce520e57cc0ffb9582546b80a32fa00682 (diff)
downloadquartz-based-queue-1ec4fae12c5e5363591013e5a759590d913d6782.tar.gz
quartz-based-queue-1ec4fae12c5e5363591013e5a759590d913d6782.tar.bz2
quartz-based-queue-1ec4fae12c5e5363591013e5a759590d913d6782.tar.xz
quartz-based-queue-1ec4fae12c5e5363591013e5a759590d913d6782.zip
wip
Diffstat (limited to 'src/test/java/io/trygvis/test/Main.java')
-rwxr-xr-xsrc/test/java/io/trygvis/test/Main.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/test/java/io/trygvis/test/Main.java b/src/test/java/io/trygvis/test/Main.java
index 0721ec9..f03d6fa 100755
--- a/src/test/java/io/trygvis/test/Main.java
+++ b/src/test/java/io/trygvis/test/Main.java
@@ -74,7 +74,9 @@ public class Main {
final Queue q = null; // queueService.lookupQueue(c, "create-article", 1);
- asyncService.registerQueue(q, createArticleCallable);
+ QueueService.TaskExecutionRequest req = new QueueService.TaskExecutionRequest(100, true);
+
+ asyncService.registerQueue(q, req, createArticleCallable);
// log.info("queue registered: ref = {}", q);
// asyncService.registerQueue("update-queue", 1, updateArticleCallable);