From abb0b2aaf4ee5e6f147987401c9b059e5a7679d2 Mon Sep 17 00:00:00 2001 From: Trygve Laugstøl Date: Sun, 9 Jun 2013 23:51:39 +0200 Subject: wip --- src/main/java/io/trygvis/spring/SpringQueueService.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'src/main/java/io/trygvis/spring') 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 -- cgit v1.2.3