1 files changed, 8 insertions, 4 deletions
diff --git a/src/main/java/io/trygvis/async/AsyncService.java b/src/main/java/io/trygvis/async/AsyncService.java
index daf99e4..9332596 100755
--- a/src/main/java/io/trygvis/async/AsyncService.java
+++ b/src/main/java/io/trygvis/async/AsyncService.java
@@ -1,9 +1,13 @@
 package io.trygvis.async;
 
 import io.trygvis.queue.Queue;
+import io.trygvis.queue.QueueExecutor;
+import io.trygvis.queue.QueueService;
 import io.trygvis.queue.Task;
 import io.trygvis.queue.TaskEffect;
 
+import java.sql.SQLException;
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -11,13 +15,13 @@ import java.util.List;
  */
 public interface AsyncService {
 
-    void registerQueue(Queue queue, TaskEffect processor);
+    QueueController registerQueue(Queue queue, QueueService.TaskExecutionRequest req, TaskEffect processor) throws SQLException;
 
-    Queue getQueue(String name);
+    QueueExecutor getQueue(String name);
 
-    Task schedule(Queue queue, List<String> args);
+    Task schedule(Queue queue, Date scheduled, List<String> args);
 
-    Task schedule(long parent, Queue queue, List<String> args);
+    Task schedule(Queue queue, long parent, Date scheduled, List<String> args);
 
     /**
      * Polls for a new state of the execution.