Pull request Compare This branch is 2725 commits behind twitter:master.
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
..
Failed to load latest commit information.
src
README.md

README.md

Sample Protobuf based RPC (see RpcIntegrationTest for more samples)
    RpcFactory factory = new RpcFactoryImpl();

    ServerBuilder serverBuilder = ServerBuilder.get()
        .maxConcurrentRequests(10);

    ClientBuilder clientBuilder = ClientBuilder
        .get()
        .hosts(String.format("localhost:%s", port))
        .hostConnectionLimit(1)
        .retries(2)
        .requestTimeout(
                Duration.apply(CLIENT_TIMEOUT_SECONDS, TimeUnit.SECONDS));


    SampleWeatherServiceImpl service = new SampleWeatherServiceImpl(80,
            null);
    RpcServer server = factory.createServer(serverBuilder, port, service,
            executorService);
    WeatherService stub = factory.<WeatherService> createStub(
            clientBuilder, WeatherService.newStub(null), executorService);

    RpcControllerWithOnFailureCallback controller = (RpcControllerWithOnFailureCallback) factory
            .createController();

    final CountDownLatch l = new CountDownLatch(1);
    final AtomicInteger result = new AtomicInteger();
    GetWeatherForecastRequest request = GetWeatherForecastRequest
            .newBuilder().setZip("80301").build();
    stub.getWeatherForecast(
            controller.onFailure(new RpcCallback<Throwable>() {

                @Override
                public void run(Throwable e) {
                }
            }), request, new RpcCallback<GetWeatherForecastResponse>() {

                @Override
                public void run(GetWeatherForecastResponse resp) {
                    result.set(resp.getTemp());
                    l.countDown();
                }
            });

    l.await(CLIENT_TIMEOUT_SECONDS + 2, TimeUnit.SECONDS);
    server.close(new Duration(TimeUnit.SECONDS.toNanos(1)));

    assertEquals(service.getTemperature(), result.get());