wip

1 files changed, 30 insertions, 28 deletions

diff --git a/src/main/java/io/trygvis/queue/AsyncService.java b/src/main/java/io/trygvis/queue/AsyncService.java
index 10f1b79..b42b550 100755
--- a/src/main/java/io/trygvis/queue/AsyncService.java
+++ b/src/main/java/io/trygvis/queue/AsyncService.java
@@ -1,28 +1,30 @@
-package io.trygvis.queue;

-

-import org.quartz.*;

-

-public interface AsyncService {

-

-    /**

-     * @param name

-     * @param interval how often the queue should be polled for missed tasks in seconds.

-     * @param callable

-     * @return

-     * @throws SchedulerException

-     */

-    Queue registerQueue(String name, int interval, AsyncCallable callable) throws SchedulerException;

-

-    Queue getQueue(String name);

-

-    Task schedule(Queue queue, String... args);

-

-    /**

-     * Polls for a new state of the execution.

-     */

-    Task update(Task ref);

-

-    interface AsyncCallable {

-        void run() throws Exception;

-    }

-}

+package io.trygvis.queue;
+
+import org.quartz.*;
+
+import java.util.List;
+
+public interface AsyncService {
+
+    /**
+     * @param name
+     * @param interval how often the queue should be polled for missed tasks in seconds.
+     * @param callable
+     * @return
+     * @throws SchedulerException
+     */
+    Queue registerQueue(String name, int interval, AsyncCallable callable) throws SchedulerException;
+
+    Queue getQueue(String name);
+
+    Task schedule(Queue queue, String... args);
+
+    /**
+     * Polls for a new state of the execution.
+     */
+    Task update(Task ref);
+
+    interface AsyncCallable {
+        void run(List<String> arguments) throws Exception;
+    }
+}