com.linkedin.r2.transport.http.server.HttpServer.stop()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(3.0k)|赞(0)|评价(0)|浏览(191)

本文整理了Java中com.linkedin.r2.transport.http.server.HttpServer.stop()方法的一些代码示例,展示了HttpServer.stop()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HttpServer.stop()方法的具体详情如下:
包路径:com.linkedin.r2.transport.http.server.HttpServer
类名称:HttpServer
方法名:stop

HttpServer.stop介绍

暂无

代码示例

代码示例来源:origin: apache/incubator-gobblin

@Override
protected void shutDown()
  throws Exception {
 if (this.httpServer.isPresent()) {
  LOGGER.info("Stopping the job execution information server");
  this.httpServer.get().stop();
 }
}

代码示例来源:origin: apache/incubator-gobblin

@Override
protected void shutDown() throws Exception {
 if (this.httpServer.isPresent()) {
  this.log.info("Stopping the {} embedded server at port {}", this.name, this.port);
  this.httpServer.get().stop();
  this.httpServer.get().waitForStop();
 }
}

代码示例来源:origin: linkedin/parseq

@AfterClass
public void shutdown() throws Exception {
 if (_server != null) {
  _server.stop();
 }
 if (_serverEngine != null) {
  _serverEngine.shutdown();
 }
 if (_serverScheduler != null) {
  _serverScheduler.shutdownNow();
 }
 for (Client client : _transportClients) {
  FutureCallback<None> callback = new FutureCallback<>();
  client.shutdown(callback);
  callback.get();
 }
 if (_clientFactory != null) {
  FutureCallback<None> callback = new FutureCallback<>();
  _clientFactory.shutdown(callback);
  callback.get();
 }
}

代码示例来源:origin: com.linkedin.pegasus/restli-server-standalone

/**
 * Stop the server
 *
 * @throws IOException server shutdown fails
 */
public void stop() throws IOException
{
 _server.stop();
}

代码示例来源:origin: com.linkedin.gobblin/gobblin-rest-server

@Override
protected void shutDown()
  throws Exception {
 if (this.httpServer.isPresent()) {
  LOGGER.info("Stopping the job execution information server");
  this.httpServer.get().stop();
 }
}

代码示例来源:origin: org.apache.gobblin/gobblin-rest-server

@Override
protected void shutDown()
  throws Exception {
 if (this.httpServer.isPresent()) {
  LOGGER.info("Stopping the job execution information server");
  this.httpServer.get().stop();
 }
}

代码示例来源:origin: com.linkedin.pegasus/restli-server-testutils

@Override
public void stop()
  throws IOException
{
 server.stop();
 engine.shutdown();
 executor.shutdown();
 scheduler.shutdown();
}

代码示例来源:origin: org.apache.gobblin/gobblin-restli-utils

@Override
protected void shutDown() throws Exception {
 if (this.httpServer.isPresent()) {
  this.log.info("Stopping the {} embedded server at port {}", this.name, this.port);
  this.httpServer.get().stop();
  this.httpServer.get().waitForStop();
 }
}

代码示例来源:origin: com.linkedin.pegasus/restli-int-test-server

public static void main(String[] args) throws IOException
{
 final int numCores = Runtime.getRuntime().availableProcessors();
 final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(numCores + 1);
 final Engine engine = new EngineBuilder()
   .setTaskExecutor(scheduler)
   .setTimerScheduler(scheduler)
   .build();
 HttpServer server = createServer(engine, DEFAULT_PORT, supportedCompression);
 server.start();
 System.out.println("HttpServer running on port " + DEFAULT_PORT + ". Press any key to stop server");
 System.in.read();
 server.stop();
 engine.shutdown();
}

相关文章