wip

1 files changed, 2 insertions, 4 deletions

diff --git a/src/test/java/io/trygvis/test/jdbc/AsyncConsumerExample.java b/src/test/java/io/trygvis/test/jdbc/AsyncConsumerExample.java
index 361c2c5..5bcffe7 100644
--- a/src/test/java/io/trygvis/test/jdbc/AsyncConsumerExample.java
+++ b/src/test/java/io/trygvis/test/jdbc/AsyncConsumerExample.java
@@ -38,8 +38,6 @@ public class AsyncConsumerExample {
             Long a = Long.valueOf(task.arguments.get(0));
             Long b = Long.valueOf(task.arguments.get(1));
 
-            System.out.println("a + b = " + a + " + " + b + " = " + (a + b));
-
             return singletonList(newTask(outputName, new Date(), Long.toString(a + b)));
         }
     };
@@ -82,8 +80,8 @@ public class AsyncConsumerExample {
         }, 1000, 1000);
 
         long start = currentTimeMillis();
-        controller.start(new ScheduledThreadPoolExecutor(1));
-        Thread.sleep(5 * 1000);
+        controller.start(new ScheduledThreadPoolExecutor(4));
+        Thread.sleep(60 * 1000);
         controller.stop();
         long end = currentTimeMillis();
         timer.cancel();