本文整理了Java中spark.Spark.stop()
方法的一些代码示例,展示了Spark.stop()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Spark.stop()
方法的具体详情如下:
包路径:spark.Spark
类名称: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();
}
}
内容来源于网络,如有侵权,请联系作者删除!