erik/kobalt
erik/kobalt
1
0
Fork 0
mirror of https://github.com/ethauvin/kobalt.git synced 2025-04-27 00:38:11 -07:00
Code Releases Activity

Spark server logs.

Browse source
This commit is contained in:
Cedric Beust 2017-02-09 10:46:23 -08:00
parent e242886aa7
commit 53f9804ea0
1 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/main/kotlin/com/beust/kobalt/app/remote/SparkServer.kt
View file

@ -47,12 +47,16 @@ class SparkServer(val initCallback: (String) -> List<Project>, val cleanUpCallba
val log = org.slf4j.LoggerFactory.getLogger("SparkServer") val log = org.slf4j.LoggerFactory.getLogger("SparkServer")
override fun run(port: Int) { override fun run(port: Int) {
log.debug("RUNNING") log.debug("Server running")
Spark.port(port) Spark.port(port)
Spark.webSocket("/v1/getDependencies", GetDependenciesHandler::class.java) Spark.webSocket("/v1/getDependencies", GetDependenciesHandler::class.java)
Spark.webSocket("/v1/getDependencyGraph", GetDependencyGraphHandler::class.java) Spark.webSocket("/v1/getDependencyGraph", GetDependencyGraphHandler::class.java)
Spark.get("/ping", { req, res -> """ { "result" : "ok" } """ }) Spark.get("/ping") { req, res ->
log.debug(" Received ping")
""" { "result" : "ok" } """
}
Spark.get("/quit", { req, res -> Spark.get("/quit", { req, res ->
log.debug(" Received quit")
Executors.newFixedThreadPool(1).let { executor -> Executors.newFixedThreadPool(1).let { executor ->
executor.submit { executor.submit {
Thread.sleep(1000) Thread.sleep(1000)