aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/io/trygvis/spring
diff options
context:
space:
mode:
authorTrygve Laugstøl <trygvis@inamo.no>2013-06-09 23:51:39 +0200
committerTrygve Laugstøl <trygvis@inamo.no>2013-06-09 23:51:39 +0200
commitabb0b2aaf4ee5e6f147987401c9b059e5a7679d2 (patch)
treebf8aeed0f29a2b81896cd48df399e133b7ebb4e0 /src/main/java/io/trygvis/spring
parent1c0fc92c719f3856653d0efcc5fe4a1fa30b7bac (diff)
downloadquartz-based-queue-abb0b2aaf4ee5e6f147987401c9b059e5a7679d2.tar.gz
quartz-based-queue-abb0b2aaf4ee5e6f147987401c9b059e5a7679d2.tar.bz2
quartz-based-queue-abb0b2aaf4ee5e6f147987401c9b059e5a7679d2.tar.xz
quartz-based-queue-abb0b2aaf4ee5e6f147987401c9b059e5a7679d2.zip
wip
Diffstat (limited to 'src/main/java/io/trygvis/spring')
-rw-r--r--src/main/java/io/trygvis/spring/SpringQueueService.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/io/trygvis/spring/SpringQueueService.java b/src/main/java/io/trygvis/spring/SpringQueueService.java
index 21746e5..271e9bf 100644
--- a/src/main/java/io/trygvis/spring/SpringQueueService.java
+++ b/src/main/java/io/trygvis/spring/SpringQueueService.java
@@ -27,10 +27,10 @@ public class SpringQueueService implements QueueService {
}
/**
- * @see JdbcQueueService#consumeAll(io.trygvis.queue.Queue, io.trygvis.queue.TaskEffect)
+ * @see JdbcQueueService#consumeAll(io.trygvis.queue.Queue, io.trygvis.queue.QueueService.TaskExecutionRequest, io.trygvis.queue.TaskEffect)
*/
- public void consume(final Queue queue, final TaskEffect effect) throws SQLException {
- queueService.consumeAll(queue, effect);
+ public void consume(final Queue queue, TaskExecutionRequest req, final TaskEffect effect) throws SQLException {
+ queueService.consumeAll(queue, req, effect);
}
@Transactional