spark.Spark.stop()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(3.7k)|赞(0)|评价(0)|浏览(699)

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

Spark.stop介绍

[英]Stops the Spark server and clears all routes
[中]停止Spark服务器并清除所有路由

代码示例

代码示例来源:origin: bwssytems/ha-bridge

udpSender = null;
stop();
if(!bridgeSettings.getBridgeControl().isStop()) {
  try {

代码示例来源:origin: aalmiray/javatrove

public void stop() {
    Spark.stop();
  }
}

代码示例来源:origin: cuba-platform/yarg

public void stop() {
  Spark.stop();
}

代码示例来源:origin: AdoptOpenJDK/jdk9-jigsaw

@Nonnull
public MonitorServer shutdown() {
  Spark.stop();
  return this;
}

代码示例来源:origin: kodokojo/kodokojo

@Override
public void stop() {
  LOGGER.info("Stopping HttpHealthCheckEndpoint.");
  Spark.stop();
}

代码示例来源:origin: despegar/spark-test

@Override
protected void after() {
  this.sparkApplication.destroy();
  Spark.stop();
}

代码示例来源:origin: lamarios/Homedash2

/**
 * the auto update process
 *
 * @param request
 * @param response
 * @return
 */
private String update(Request request, Response response) {
  ExecutorService exec = Executors.newSingleThreadExecutor();
  exec.execute(() -> {
    try {
      logger.info("Downloading last version");
      File latestVersion = updater.downloadLatestVersion();
      logger.info("Latest version downloaded : [{}]", latestVersion.getAbsolutePath());
      //Stopping the server so we can update peacefully
      if (updater.isFolderStructureOkForAutoUpdate()) {
        Spark.stop();
        try {
          updater.stopHomedashAndTriggerUpdate(latestVersion.toPath().toAbsolutePath());
        } catch (Exception e) {
          logger.error("error while updating, restarting Spark", e);
          Spark.init();
        }
      }
    } catch (Exception e) {
      logger.error("Error while downloading the latest version", e);
    }
  });
  return "Homedash is updating and will restart on its own, try to stay still.";
}

代码示例来源:origin: renatoathaydes/rawhttp

@AfterClass
public static void stopServer() {
  Spark.stop();
}

代码示例来源:origin: cagataygurturk/lambadaframework

@Override
public void execute() throws MojoExecutionException {
  try {
    printLogo();
    getLog().info(LOG_SEPERATOR);
    getLog().info("Starting web server at port " + serverPort);
    port(serverPort);
    threadPool(8);
    setUpServer();
    awaitInitialization();
    while (10 != System.in.read()) {
      Thread.sleep(500);
    }
    stop();
  } catch (Exception e) {
    throw new MojoExecutionException("Exception at deployment", e);
  }
}

代码示例来源:origin: ingenieux/lambada

@Override
protected void executeInternal() throws Exception {
 setupStageVariables();
 loadPathHandlers();
 port(serverPort);
 threadPool(8);
 setupServer();
 awaitInitialization();
 getLog().info(format("Server is alive on http://%s:%d/%s/", "127.0.0.1", this.serverPort, this.stageName));
 while (10 != System.in.read()) {
  Thread.sleep(500);
 }
 stop();
}

代码示例来源:origin: petersamokhin/vk-bot-java-sdk

Spark.stop();
  serverIsStarted = false;
} else {

代码示例来源:origin: pyloque/captain

public void halt() {
    if (this.watcher.isAlive()) {
      this.watcher.interrupt();
      this.watcher.quit();
    }
    this.redis.close();
    Spark.stop();
  }
}

代码示例来源:origin: petersamokhin/vk-bot-java-sdk

Spark.stop();
  serverIsStarted = false;
} else {

代码示例来源:origin: mgtechsoftware/smockin

@Override
public void shutdown() throws MockServerException {
  try {
    serverSideEventService.interruptAndClearAllHeartBeatThreads();
    Spark.stop();
    // Having dug around the source code, 'Spark.stop()' runs off a different thread when stopping the server and removing it's state such as routes, etc.
    // This means that calling 'Spark.port()' immediately after stop, results in an IllegalStateException, as the
    // 'initialized' flag is checked in the current thread and is still marked as true.
    // (The error thrown: java.lang.IllegalStateException: This must be done before route mapping has begun)
    // Short of editing the Spark source to fix this, I have therefore had to add this hack to buy the 'stop' thread time to complete.
    Thread.sleep(3000);
    synchronized (monitor) {
      serverState.setRunning(false);
    }
    clearState();
    proxyServer.shutdown();
  } catch (Throwable ex) {
    throw new MockServerException(ex);
  } finally {
    clearDeployedMocks();
  }
}

相关文章