From 6ab5741f811a4a2f6b5672811899f19a726786ec Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Mon, 17 Jun 2013 20:43:06 +0200
Subject: wip

---
 src/test/java/io/trygvis/test/jdbc/AsyncConsumerExample.java | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

(limited to 'src/test/java/io/trygvis/test/jdbc/AsyncConsumerExample.java')

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();
-- 
cgit v1.2.3