diff options
Diffstat (limited to 'src/main/java/com/orbekk/protobuf/SimpleProtobufClient.java')
-rw-r--r-- | src/main/java/com/orbekk/protobuf/SimpleProtobufClient.java | 39 |
1 files changed, 0 insertions, 39 deletions
diff --git a/src/main/java/com/orbekk/protobuf/SimpleProtobufClient.java b/src/main/java/com/orbekk/protobuf/SimpleProtobufClient.java deleted file mode 100644 index 7d0dc6a..0000000 --- a/src/main/java/com/orbekk/protobuf/SimpleProtobufClient.java +++ /dev/null @@ -1,39 +0,0 @@ -package com.orbekk.protobuf; - -import java.util.concurrent.CountDownLatch; -import java.util.logging.Logger; - -import com.google.protobuf.RpcCallback; - -public class SimpleProtobufClient { - static final Logger logger = - Logger.getLogger(SimpleProtobufClient.class.getName()); - -// public void run() { -// RpcChannel channel = RpcChannel.create("localhost", 10000); -// Test.TestService test = Test.TestService.newStub(channel); -// Test.TestRequest request = Test.TestRequest.newBuilder() -// .setId("Hello!") -// .build(); -// int count = 10; -// final CountDownLatch stop = new CountDownLatch(count); -// for (int i = 0; i < count; i++) { -// logger.info("Sending request."); -// test.run(null, request, new RpcCallback<Test.TestResponse>() { -// @Override public void run(Test.TestResponse response) { -// System.out.println("Response from server: " + response); -// stop.countDown(); -// } -// }); -// } -// try { -// stop.await(); -// } catch (InterruptedException e) { -// // Stop waiting. -// } -// } -// -// public static void main(String[] args) { -// new SimpleProtobufClient().run(); -// } -} |