Showing
1 changed file
with
2 additions
and
2 deletions
| ... | @@ -102,7 +102,7 @@ private static Logger log = LoggerFactory.getLogger(SimpleNettyClient.class); | ... | @@ -102,7 +102,7 @@ private static Logger log = LoggerFactory.getLogger(SimpleNettyClient.class); |
| 102 | // System.out.println("Got back:" + new String(response.get(2, TimeUnit.SECONDS))); | 102 | // System.out.println("Got back:" + new String(response.get(2, TimeUnit.SECONDS))); |
| 103 | } | 103 | } |
| 104 | 104 | ||
| 105 | - sleep(1000); | 105 | + //sleep(1000); |
| 106 | log.info("measuring async sender"); | 106 | log.info("measuring async sender"); |
| 107 | Timer sendAsyncTimer = metrics.createTimer(component, feature, "AsyncSender"); | 107 | Timer sendAsyncTimer = metrics.createTimer(component, feature, "AsyncSender"); |
| 108 | 108 | ||
| ... | @@ -111,7 +111,7 @@ private static Logger log = LoggerFactory.getLogger(SimpleNettyClient.class); | ... | @@ -111,7 +111,7 @@ private static Logger log = LoggerFactory.getLogger(SimpleNettyClient.class); |
| 111 | messaging.sendAsync(endpoint, "simple", "Hello World".getBytes()); | 111 | messaging.sendAsync(endpoint, "simple", "Hello World".getBytes()); |
| 112 | context.stop(); | 112 | context.stop(); |
| 113 | } | 113 | } |
| 114 | - sleep(1000); | 114 | + sleep(10000); |
| 115 | } | 115 | } |
| 116 | 116 | ||
| 117 | public static void stop() { | 117 | public static void stop() { | ... | ... |
-
Please register or login to post a comment