From 7d704feb86c44fca57941d223e8605b55fcf68f0 Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Wed, 29 May 2013 22:16:50 +0200
Subject: o Splitting out the parts that implement the "async" features vs the
 "queue" features.

---
 src/main/java/io/trygvis/async/AsyncService.java | 37 ++++++++++++++++++++++++
 1 file changed, 37 insertions(+)
 create mode 100755 src/main/java/io/trygvis/async/AsyncService.java

(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
new file mode 100755
index 0000000..e90a0e4
--- /dev/null
+++ b/src/main/java/io/trygvis/async/AsyncService.java
@@ -0,0 +1,37 @@
+package io.trygvis.async;
+
+import io.trygvis.queue.Queue;
+import io.trygvis.queue.Task;
+import org.quartz.SchedulerException;
+
+import java.util.List;
+
+/**
+ * A simple framework for running tasks.
+ */
+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);
+
+    Task schedule(long parent, 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;
+    }
+}
-- 
cgit v1.2.3