1 files changed, 11 insertions, 4 deletions
diff --git a/src/test/java/io/trygvis/test/UpdateArticleCallable.java b/src/test/java/io/trygvis/test/UpdateArticleCallable.java
index f50c10a..6aff20f 100755
--- a/src/test/java/io/trygvis/test/UpdateArticleCallable.java
+++ b/src/test/java/io/trygvis/test/UpdateArticleCallable.java
@@ -1,6 +1,7 @@
 package io.trygvis.test;
 
-import io.trygvis.async.AsyncService;
+import io.trygvis.queue.Task;
+import io.trygvis.queue.TaskEffect;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Component;
@@ -9,14 +10,18 @@ import java.util.Date;
 import java.util.List;
 import java.util.Random;
 
+import static java.util.Collections.emptyList;
+
 @Component("updateArticle")
-public class UpdateArticleCallable
-    implements AsyncService.AsyncCallable {
+public class UpdateArticleCallable implements TaskEffect {
     private final Logger log = LoggerFactory.getLogger(getClass());
 
     private final Random r = new Random();
 
-    public void run(List<String> arguments) throws Exception {
+    @Override
+    public List<Task> apply(Task task) throws Exception {
+        List<String> arguments = task.arguments;
+
         log.info("UpdateArticeJob.run: BEGIN");
 
         Date now = new Date();
@@ -36,5 +41,7 @@ public class UpdateArticleCallable
 */
 
         log.info("UpdateArticeJob.run: END");
+
+        return emptyList();
     }
 }