Examples of shutdown()

Examples of com.linkedin.norbert.cluster.javaapi.ClusterClient.shutdown()

51
52
53
54
55
56
57
58
      e.printStackTrace();
    } catch (TimeoutException e) {
      e.printStackTrace();
    }

    cc.shutdown();
  }
}
View Full Code Here

Examples of com.linkedin.norbert.cluster.javaapi.ZooKeeperClusterClient.shutdown()

51
52
53
54
55
56
57
58
      e.printStackTrace();
    } catch (TimeoutException e) {
      e.printStackTrace();
    }

    cc.shutdown();
  }
}
View Full Code Here

Examples of com.linkedin.parseq.Engine.shutdown()

64
65
66
67
68
69
70
71
72
73
      ExampleUtil.printTracingResults(classifications);
    }
    finally
    {
      serviceScheduler.shutdownNow();
      engine.shutdown();
      scheduler.shutdownNow();
    }
  }
}
View Full Code Here

Examples of com.linkedin.r2.transport.common.Client.shutdown()

300
301
302
303
304
305
306
307
308
309
310
    Assert.assertEquals(greetingResponse.getEntity().getMessage(), NEW_MESSAGE);

    // shut down client
    FutureCallback<None> futureCallback = new FutureCallback<None>();
    r2Client.shutdown(futureCallback);
    futureCallback.get();
  }

  @Test(dataProvider = com.linkedin.restli.internal.common.TestConstants.RESTLI_PROTOCOL_1_2_PREFIX + "requestOptionsDataProvider")
  public void testOldCookbookInBatch(RestliRequestOptions requestOptions) throws Exception
View Full Code Here

Examples of com.linkedin.r2.transport.common.bridge.client.TransportClient.shutdown()

217
218
219
220
221
222
223
224
225
226
227
  {
    TransportClient client = new HttpClientFactory().getClient(
            Collections.<String, String>emptyMap());

    FutureCallback<None> shutdownCallback = new FutureCallback<None>();
    client.shutdown(shutdownCallback);
    shutdownCallback.get(30, TimeUnit.SECONDS);

    // Now verify a new request will also fail
    RestRequest r = new RestRequestBuilder(URI.create("http://no.such.host.linkedin.com")).build();
    FutureCallback<RestResponse> callback = new FutureCallback<RestResponse>();
View Full Code Here

Examples of com.linkedin.r2.transport.common.bridge.client.TransportClientAdapter.shutdown()

300
301
302
303
304
305
306
307
308
309
310
    Assert.assertEquals(greetingResponse.getEntity().getMessage(), NEW_MESSAGE);

    // shut down client
    FutureCallback<None> futureCallback = new FutureCallback<None>();
    r2Client.shutdown(futureCallback);
    futureCallback.get();
  }

  @Test(dataProvider = com.linkedin.restli.internal.common.TestConstants.RESTLI_PROTOCOL_1_2_PREFIX + "requestOptionsDataProvider")
  public void testOldCookbookInBatch(RestliRequestOptions requestOptions) throws Exception
View Full Code Here

Examples of com.linkedin.r2.transport.http.client.HttpClientFactory.shutdown()

70
71
72
73
74
75
76
77
78
79
    // Print the response
    System.out.println(resp.getEntity().getFortune());

    // shutdown
    restClient.shutdown(new FutureCallback<None>());
    http.shutdown(new FutureCallback<None>());
  }
  private static final FortunesBuilders _fortuneBuilder = new FortunesBuilders();
}
View Full Code Here

Examples of com.linkedin.restli.client.RestClient.shutdown()

69
70
71
72
73
74
75
76
77
78
79
    // Print the response
    System.out.println(resp.getEntity().getFortune());

    // shutdown
    restClient.shutdown(new FutureCallback<None>());
    http.shutdown(new FutureCallback<None>());
  }
  private static final FortunesBuilders _fortuneBuilder = new FortunesBuilders();
}
View Full Code Here

Examples of com.meetup.memcached.SockIOPool.shutDown()

371
372
373
374
375
376
377
378
379
380
381
          mc = new MemcachedClient( "test" );
          mc.flushAll();
          runAlTests( mc );
        } finally {
          pool.shutDown();
        }
        log.warn("Finished: " + ((System.currentTimeMillis() - time)/1000) + "s");
    }

    /**
 
View Full Code Here

Examples of com.mycila.testing.core.api.TestNotifier.shutdown()

46
47
48
49
50
51
52
53
54
55
56
    @Override
    public final void runBare() throws Throwable {
        final TestNotifier testNotifier = MycilaTesting.from(getClass()).configure(this).createNotifier(this);
        ShutdownHook.get().add(new Closeable() {
            public void close() throws Exception {
                testNotifier.shutdown();
            }
        });
        testNotifier.prepare();
        try {
            setUp();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.