diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-10 22:23:13 +0200 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-10 22:23:13 +0200 |
commit | 4b0bab9e722cf77ca0049c54515e8c93acefa355 (patch) | |
tree | e9d74a7cf999e48a9f143027784ef4e8e0c02c0a /src/main/java/io/trygvis/async/QueueThread.java | |
parent | abb0b2aaf4ee5e6f147987401c9b059e5a7679d2 (diff) | |
download | quartz-based-queue-4b0bab9e722cf77ca0049c54515e8c93acefa355.tar.gz quartz-based-queue-4b0bab9e722cf77ca0049c54515e8c93acefa355.tar.bz2 quartz-based-queue-4b0bab9e722cf77ca0049c54515e8c93acefa355.tar.xz quartz-based-queue-4b0bab9e722cf77ca0049c54515e8c93acefa355.zip |
wip
Diffstat (limited to 'src/main/java/io/trygvis/async/QueueThread.java')
-rw-r--r-- | src/main/java/io/trygvis/async/QueueThread.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/main/java/io/trygvis/async/QueueThread.java b/src/main/java/io/trygvis/async/QueueThread.java index 558e769..ea77911 100644 --- a/src/main/java/io/trygvis/async/QueueThread.java +++ b/src/main/java/io/trygvis/async/QueueThread.java @@ -56,17 +56,19 @@ class QueueThread implements Runnable { public void run() { while (shouldRun) { try { + TaskExecutionRequest req = new TaskExecutionRequest(100, true); + List<Task> tasks = sqlEffectExecutor.transaction(new SqlEffect<List<Task>>() { @Override public List<Task> doInConnection(Connection c) throws SQLException { - return queueSystem.createTaskDao(c).findByQueueAndState(queue.name, NEW); + return queueSystem.createTaskDao(c).findByQueueAndState(queue.name, NEW, 100); } }); log.info("Found {} tasks on queue {}", tasks.size(), queue.name); if (tasks.size() > 0) { - queueService.executeTask(new TaskExecutionRequest(true), taskEffect, tasks); + queueService.executeTask(req, taskEffect, tasks); } } catch (Throwable e) { log.warn("Error while executing tasks.", e); |