Showing
1 changed file
with
3 additions
and
4 deletions
... | @@ -28,18 +28,17 @@ public final class SimpleClient { | ... | @@ -28,18 +28,17 @@ public final class SimpleClient { |
28 | } | 28 | } |
29 | metrics.registerMetric(component, feature, "AsyncTimer", sendAsyncTimer); | 29 | metrics.registerMetric(component, feature, "AsyncTimer", sendAsyncTimer); |
30 | 30 | ||
31 | - Timer sendAndRecieveTimer = metrics.createTimer(component, feature, "SendAndReceive"); | 31 | + Timer sendAndReceiveTimer = metrics.createTimer(component, feature, "SendAndReceive"); |
32 | final int iterations = 1000000; | 32 | final int iterations = 1000000; |
33 | for (int i = 0; i < iterations; i++) { | 33 | for (int i = 0; i < iterations; i++) { |
34 | - Timer.Context context = sendAndRecieveTimer.time(); | 34 | + Timer.Context context = sendAndReceiveTimer.time(); |
35 | Response<String> response = messaging | 35 | Response<String> response = messaging |
36 | .sendAndReceive(new Endpoint("localhost", 8080), "echo", | 36 | .sendAndReceive(new Endpoint("localhost", 8080), "echo", |
37 | "Hello World"); | 37 | "Hello World"); |
38 | System.out.println("Got back:" + response.get(2, TimeUnit.SECONDS)); | 38 | System.out.println("Got back:" + response.get(2, TimeUnit.SECONDS)); |
39 | context.stop(); | 39 | context.stop(); |
40 | } | 40 | } |
41 | - metrics.registerMetric(component, feature, "AsyncTimer", sendAndRecieveTimer); | 41 | + metrics.registerMetric(component, feature, "AsyncTimer", sendAndReceiveTimer); |
42 | - | ||
43 | } | 42 | } |
44 | 43 | ||
45 | public static class TestNettyMessagingService extends NettyMessagingService { | 44 | public static class TestNettyMessagingService extends NettyMessagingService { | ... | ... |
-
Please register or login to post a comment