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");
     }