diff options
Diffstat (limited to 'src/main/java/io/trygvis/async/AsyncService.java')
-rwxr-xr-x | src/main/java/io/trygvis/async/AsyncService.java | 7 |
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; - } } |