aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/io/trygvis/async/QueueThread.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/io/trygvis/async/QueueThread.java')
-rw-r--r--src/main/java/io/trygvis/async/QueueThread.java6
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);