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;
+        }
+    }
 }