1 files changed, 5 insertions, 4 deletions
diff --git a/src/test/java/io/trygvis/test/Main.java b/src/test/java/io/trygvis/test/Main.java
index 43ee971..0721ec9 100755
--- a/src/test/java/io/trygvis/test/Main.java
+++ b/src/test/java/io/trygvis/test/Main.java
@@ -4,6 +4,7 @@ import io.trygvis.async.AsyncService;
 import io.trygvis.queue.Queue;
 import io.trygvis.queue.QueueService;
 import io.trygvis.queue.Task;
+import io.trygvis.queue.TaskEffect;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.slf4j.bridge.SLF4JBridgeHandler;
@@ -62,22 +63,22 @@ public class Main {
 
     @Autowired
     @Qualifier("createArticle")
-    private AsyncService.AsyncCallable createArticleCallable;
+    private TaskEffect createArticleCallable;
 
     @Autowired
     @Qualifier("updateArticle")
-    private AsyncService.AsyncCallable updateArticleCallable;
+    private TaskEffect updateArticleCallable;
 
     public void run() throws Exception {
         log.info("Main.run");
 
-        final Queue q = null; // queueService.getQueue(c, "create-article", 1);
+        final Queue q = null; // queueService.lookupQueue(c, "create-article", 1);
 
         asyncService.registerQueue(q, createArticleCallable);
 //        log.info("queue registered: ref = {}", q);
 //        asyncService.registerQueue("update-queue", 1, updateArticleCallable);
 
-//        q = asyncService.getQueue("create-queue");
+//        q = asyncService.lookupQueue("create-queue");
 
         final List<Task> tasks = new ArrayList<>();