diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-16 12:07:43 +0200 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2013-06-16 12:07:43 +0200 |
commit | 1ec4fae12c5e5363591013e5a759590d913d6782 (patch) | |
tree | bac64a4e0e86a3227ca21591b8efc34aee6223da /src/test/java/io/trygvis/test/spring/PlainSpringTest.java | |
parent | 54d7b2ce520e57cc0ffb9582546b80a32fa00682 (diff) | |
download | quartz-based-queue-1ec4fae12c5e5363591013e5a759590d913d6782.tar.gz quartz-based-queue-1ec4fae12c5e5363591013e5a759590d913d6782.tar.bz2 quartz-based-queue-1ec4fae12c5e5363591013e5a759590d913d6782.tar.xz quartz-based-queue-1ec4fae12c5e5363591013e5a759590d913d6782.zip |
wip
Diffstat (limited to 'src/test/java/io/trygvis/test/spring/PlainSpringTest.java')
-rw-r--r-- | src/test/java/io/trygvis/test/spring/PlainSpringTest.java | 15 |
1 files changed, 10 insertions, 5 deletions
diff --git a/src/test/java/io/trygvis/test/spring/PlainSpringTest.java b/src/test/java/io/trygvis/test/spring/PlainSpringTest.java index d06d8d6..38d3361 100644 --- a/src/test/java/io/trygvis/test/spring/PlainSpringTest.java +++ b/src/test/java/io/trygvis/test/spring/PlainSpringTest.java @@ -1,7 +1,7 @@ package io.trygvis.test.spring; import io.trygvis.async.AsyncService; -import io.trygvis.queue.Queue; +import io.trygvis.queue.QueueExecutor; import io.trygvis.queue.QueueService; import io.trygvis.queue.Task; import io.trygvis.queue.TaskEffect; @@ -13,6 +13,7 @@ import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import java.sql.SQLException; +import java.util.Date; import java.util.List; import java.util.concurrent.atomic.AtomicReference; @@ -33,6 +34,8 @@ public class PlainSpringTest { @Autowired private QueueService queueService; + private final QueueService.TaskExecutionRequest req = new QueueService.TaskExecutionRequest(100, true); + static { String username = getProperty("user.name"); setProperty("database.url", getProperty("jdbc.url", "jdbc:postgresql://localhost/" + username)); @@ -42,9 +45,9 @@ public class PlainSpringTest { @Test public void testBasic() throws SQLException, InterruptedException { - Queue test = queueService.getQueue("test", 10, true); + QueueExecutor test = queueService.getQueue("test", 10, true); final AtomicReference<List<String>> ref = new AtomicReference<>(); - asyncService.registerQueue(test, new TaskEffect() { + asyncService.registerQueue(test.queue, req, new TaskEffect() { @Override public List<Task> apply(Task task) throws Exception { System.out.println("PlainSpringTest.run"); @@ -58,12 +61,14 @@ public class PlainSpringTest { synchronized (ref) { System.out.println("Scheduling task"); - asyncService.schedule(test, asList("hello", "world")); - System.out.println("Waiting"); + queueService.schedule(test.queue, new Date(), asList("hello", "world")); + System.out.println("Task scheduled, waiting"); ref.wait(1000); + System.out.println("Back!"); } List<String> args = ref.get(); + System.out.println("args = " + args); assertNotNull(args); assertThat(args).containsExactly("hello", "world"); } |