diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-09 23:51:39 +0200 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-09 23:51:39 +0200 |
commit | abb0b2aaf4ee5e6f147987401c9b059e5a7679d2 (patch) | |
tree | bf8aeed0f29a2b81896cd48df399e133b7ebb4e0 /src/main/java/io/trygvis/queue/QueueService.java | |
parent | 1c0fc92c719f3856653d0efcc5fe4a1fa30b7bac (diff) | |
download | quartz-based-queue-abb0b2aaf4ee5e6f147987401c9b059e5a7679d2.tar.gz quartz-based-queue-abb0b2aaf4ee5e6f147987401c9b059e5a7679d2.tar.bz2 quartz-based-queue-abb0b2aaf4ee5e6f147987401c9b059e5a7679d2.tar.xz quartz-based-queue-abb0b2aaf4ee5e6f147987401c9b059e5a7679d2.zip |
wip
Diffstat (limited to 'src/main/java/io/trygvis/queue/QueueService.java')
-rw-r--r-- | src/main/java/io/trygvis/queue/QueueService.java | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/src/main/java/io/trygvis/queue/QueueService.java b/src/main/java/io/trygvis/queue/QueueService.java index 9773766..ee74bf4 100644 --- a/src/main/java/io/trygvis/queue/QueueService.java +++ b/src/main/java/io/trygvis/queue/QueueService.java @@ -5,9 +5,18 @@ import java.util.Date; import java.util.List; public interface QueueService { - void consume(Queue queue, TaskEffect effect) throws SQLException; + void consume(Queue queue, TaskExecutionRequest req, TaskEffect effect) throws SQLException; Queue getQueue(String name, int interval, boolean autoCreate) throws SQLException; void schedule(Queue queue, Date scheduled, List<String> arguments) throws SQLException; + + public static class TaskExecutionRequest { + public final boolean stopOnError; + // TODO: saveExceptions + + public TaskExecutionRequest(boolean stopOnError) { + this.stopOnError = stopOnError; + } + } } |