diff options
Diffstat (limited to 'src/test/java/io/trygvis/test/jdbc/AsyncConsumerExample.java')
-rw-r--r-- | src/test/java/io/trygvis/test/jdbc/AsyncConsumerExample.java | 6 |
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(); |