diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-16 12:07:43 +0200 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-16 12:07:43 +0200 |
commit | 1ec4fae12c5e5363591013e5a759590d913d6782 (patch) | |
tree | bac64a4e0e86a3227ca21591b8efc34aee6223da /src/test/java/io/trygvis/test/Main.java | |
parent | 54d7b2ce520e57cc0ffb9582546b80a32fa00682 (diff) | |
download | quartz-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-x | src/test/java/io/trygvis/test/Main.java | 4 |
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); |