1 files changed, 4 insertions, 0 deletions
diff --git a/src/main/java/io/trygvis/queue/QueueService.java b/src/main/java/io/trygvis/queue/QueueService.java
index eee14ed..f4ce536 100644
--- a/src/main/java/io/trygvis/queue/QueueService.java
+++ b/src/main/java/io/trygvis/queue/QueueService.java
@@ -15,6 +15,10 @@ public interface QueueService {
         // TODO: saveExceptions
 
         public TaskExecutionRequest(long chunkSize, boolean stopOnError) {
+            if (chunkSize <= 0) {
+                throw new IllegalArgumentException("chunkSize has to be bigger than zero.");
+            }
+
             this.chunkSize = chunkSize;
             this.stopOnError = stopOnError;
         }