wip

1 files changed, 2 insertions, 5 deletions

diff --git a/src/main/java/io/trygvis/async/AsyncService.java b/src/main/java/io/trygvis/async/AsyncService.java
index 17d53e9..daf99e4 100755
--- a/src/main/java/io/trygvis/async/AsyncService.java
+++ b/src/main/java/io/trygvis/async/AsyncService.java
@@ -2,6 +2,7 @@ package io.trygvis.async;
 
 import io.trygvis.queue.Queue;
 import io.trygvis.queue.Task;
+import io.trygvis.queue.TaskEffect;
 
 import java.util.List;
 
@@ -10,7 +11,7 @@ import java.util.List;
  */
 public interface AsyncService {
 
-    void registerQueue(Queue queue, final AsyncService.AsyncCallable callable);
+    void registerQueue(Queue queue, TaskEffect processor);
 
     Queue getQueue(String name);
 
@@ -22,8 +23,4 @@ public interface AsyncService {
      * Polls for a new state of the execution.
      */
     Task update(Task ref);
-
-    interface AsyncCallable {
-        void run(List<String> arguments) throws Exception;
-    }
 }