1 files changed, 11 insertions, 3 deletions
diff --git a/src/test/java/io/trygvis/test/CreateArticleCallable.java b/src/test/java/io/trygvis/test/CreateArticleCallable.java
index a822a51..396fc89 100755
--- a/src/test/java/io/trygvis/test/CreateArticleCallable.java
+++ b/src/test/java/io/trygvis/test/CreateArticleCallable.java
@@ -1,25 +1,31 @@
 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;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.Collections;
 import java.util.Date;
 import java.util.List;
 import java.util.Random;
 
+import static java.util.Collections.emptyList;
 import static org.springframework.transaction.annotation.Propagation.MANDATORY;
 
 @Component("createArticle")
 @Transactional(propagation = MANDATORY)
-public class CreateArticleCallable implements AsyncService.AsyncCallable {
+public class CreateArticleCallable implements TaskEffect {
     private final Logger log = LoggerFactory.getLogger(getClass());
 
     private Random random = 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("CreateArticeJob.run: BEGIN");
 
         if (random.nextInt() % 3 == 0) {
@@ -34,5 +40,7 @@ public class CreateArticleCallable implements AsyncService.AsyncCallable {
 //        entityManager.persist(article);
 
         log.info("CreateArticeJob.run: END");
+
+        return emptyList();
     }
 }