summaryrefslogtreecommitdiff
path: root/same/src/main/java/com/orbekk/same/benchmark/ClientBenchmark.java
diff options
context:
space:
mode:
Diffstat (limited to 'same/src/main/java/com/orbekk/same/benchmark/ClientBenchmark.java')
-rw-r--r--same/src/main/java/com/orbekk/same/benchmark/ClientBenchmark.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/same/src/main/java/com/orbekk/same/benchmark/ClientBenchmark.java b/same/src/main/java/com/orbekk/same/benchmark/ClientBenchmark.java
index 6108630..a2fc663 100644
--- a/same/src/main/java/com/orbekk/same/benchmark/ClientBenchmark.java
+++ b/same/src/main/java/com/orbekk/same/benchmark/ClientBenchmark.java
@@ -5,7 +5,7 @@ import java.net.UnknownHostException;
import java.util.concurrent.CountDownLatch;
import com.google.protobuf.RpcCallback;
-import com.orbekk.protobuf.NewRpcChannel;
+import com.orbekk.protobuf.RpcChannel;
import com.orbekk.protobuf.Rpc;
import com.orbekk.protobuf.RpcChannel;
import com.orbekk.same.benchmark.Example.Data;
@@ -17,9 +17,9 @@ public class ClientBenchmark {
public static void benchmark(String host, int port, int warmupIterations,
int iterations) throws InterruptedException {
- NewRpcChannel channel = null;
+ RpcChannel channel = null;
try {
- channel = NewRpcChannel.create(host, port);
+ channel = RpcChannel.create(host, port);
Example.Service service = Example.Service.newStub(channel);
ClientBenchmark benchmark = new ClientBenchmark(
service, warmupIterations, iterations);