aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/io/trygvis/queue/QueueService.java
diff options
context:
space:
mode:
authorTrygve Laugstøl <trygvis@inamo.no>2013-06-16 21:26:17 +0200
committerTrygve Laugstøl <trygvis@inamo.no>2013-06-16 21:26:17 +0200
commite57f313713ee0fc52d7dd1247c51914d1462dfc2 (patch)
treef39a49b967f6f18d0637e61f2dd4d8081615283b /src/main/java/io/trygvis/queue/QueueService.java
parent1ec4fae12c5e5363591013e5a759590d913d6782 (diff)
downloadquartz-based-queue-e57f313713ee0fc52d7dd1247c51914d1462dfc2.tar.gz
quartz-based-queue-e57f313713ee0fc52d7dd1247c51914d1462dfc2.tar.bz2
quartz-based-queue-e57f313713ee0fc52d7dd1247c51914d1462dfc2.tar.xz
quartz-based-queue-e57f313713ee0fc52d7dd1247c51914d1462dfc2.zip
wip
Diffstat (limited to 'src/main/java/io/trygvis/queue/QueueService.java')
-rw-r--r--src/main/java/io/trygvis/queue/QueueService.java4
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;
}