diff options
| author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-04-11 14:53:23 +0200 |
|---|---|---|
| committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-04-11 14:53:23 +0200 |
| commit | a4414f27a1076dbf53224c22765c4dc64c5b7bd8 (patch) | |
| tree | 609d14afce4d17eb57d2996696d94576af70192c /src/main/java/com/orbekk/example | |
| parent | 6f414b99c94f5e1562785f9f2b95940a50a70a88 (diff) | |
Remove old RpcChannel.
Fix tests with NewRpcChannel.
Diffstat (limited to 'src/main/java/com/orbekk/example')
| -rw-r--r-- | src/main/java/com/orbekk/example/ExampleClient.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/com/orbekk/example/ExampleClient.java b/src/main/java/com/orbekk/example/ExampleClient.java index 3590182..e047ad9 100644 --- a/src/main/java/com/orbekk/example/ExampleClient.java +++ b/src/main/java/com/orbekk/example/ExampleClient.java @@ -19,14 +19,14 @@ import java.util.concurrent.CountDownLatch; import com.google.protobuf.RpcCallback; import com.orbekk.example.Example.FortuneReply; +import com.orbekk.protobuf.NewRpcChannel; import com.orbekk.protobuf.Rpc; -import com.orbekk.protobuf.RpcChannel; public class ExampleClient { public void runClient(int port) { - RpcChannel channel = null; + NewRpcChannel channel = null; try { - channel = RpcChannel.create("localhost", port); + channel = NewRpcChannel.createOrNull("localhost", port); Example.FortuneService service = Example.FortuneService.newStub(channel); printFortune(service); |
