From 33e3be55dc2d815cbd0208bf59d12a7e727f3105 Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Sun, 9 Jun 2013 15:15:46 +0200
Subject: wip

---
 src/main/java/io/trygvis/async/AsyncService.java | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

(limited to 'src/main/java/io/trygvis/async/AsyncService.java')

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;
-    }
 }
-- 
cgit v1.2.3