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);