Package spark.embeddedserver.jetty
Class EmbeddedJettyServer
java.lang.Object
spark.embeddedserver.jetty.EmbeddedJettyServer
- All Implemented Interfaces:
EmbeddedServer
Spark server implementation
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final org.eclipse.jetty.server.Handler
private final org.slf4j.Logger
private static final String
private org.eclipse.jetty.server.Server
private final JettyServerFactory
private static final int
private org.eclipse.jetty.util.thread.ThreadPool
private Map
<String, WebSocketHandlerWrapper> -
Constructor Summary
ConstructorsConstructorDescriptionEmbeddedJettyServer
(JettyServerFactory serverFactory, org.eclipse.jetty.server.Handler handler) -
Method Summary
Modifier and TypeMethodDescriptionint
void
configureWebSockets
(Map<String, WebSocketHandlerWrapper> webSocketHandlers, Optional<Integer> webSocketIdleTimeoutMillis) Configures the web sockets for the embedded server.void
Extinguish the embedded server.int
ignite
(String host, int port, SslStores sslStores, int maxThreads, int minThreads, int threadIdleTimeoutMillis) Ignites the embedded server, listening on the specified port, running SSL secured with the specified keystore and truststore.void
join()
Joins the embedded server thread(s).withThreadPool
(org.eclipse.jetty.util.thread.ThreadPool threadPool) Sets optional thread pool for jetty server.
-
Field Details
-
SPARK_DEFAULT_PORT
private static final int SPARK_DEFAULT_PORT- See Also:
-
NAME
- See Also:
-
serverFactory
-
handler
private final org.eclipse.jetty.server.Handler handler -
server
private org.eclipse.jetty.server.Server server -
logger
private final org.slf4j.Logger logger -
webSocketHandlers
-
webSocketIdleTimeoutMillis
-
threadPool
private org.eclipse.jetty.util.thread.ThreadPool threadPool
-
-
Constructor Details
-
EmbeddedJettyServer
public EmbeddedJettyServer(JettyServerFactory serverFactory, org.eclipse.jetty.server.Handler handler)
-
-
Method Details
-
configureWebSockets
public void configureWebSockets(Map<String, WebSocketHandlerWrapper> webSocketHandlers, Optional<Integer> webSocketIdleTimeoutMillis) Description copied from interface:EmbeddedServer
Configures the web sockets for the embedded server.- Specified by:
configureWebSockets
in interfaceEmbeddedServer
- Parameters:
webSocketHandlers
- - web socket handlers.webSocketIdleTimeoutMillis
- - Optional WebSocket idle timeout (ms).
-
ignite
public int ignite(String host, int port, SslStores sslStores, int maxThreads, int minThreads, int threadIdleTimeoutMillis) throws Exception Ignites the embedded server, listening on the specified port, running SSL secured with the specified keystore and truststore. If truststore is null, keystore is reused.- Specified by:
ignite
in interfaceEmbeddedServer
- Parameters:
host
- The address to listen onport
- - the portsslStores
- - The SSL sslStores.maxThreads
- - max nbr of threads.minThreads
- - min nbr of threads.threadIdleTimeoutMillis
- - idle timeout (ms).- Returns:
- The port number the server was launched on.
- Throws:
Exception
-
join
Joins the embedded server thread(s).- Specified by:
join
in interfaceEmbeddedServer
- Throws:
InterruptedException
-
extinguish
public void extinguish()Extinguish the embedded server.- Specified by:
extinguish
in interfaceEmbeddedServer
-
activeThreadCount
public int activeThreadCount()- Specified by:
activeThreadCount
in interfaceEmbeddedServer
- Returns:
- The approximate number of currently active threads
-
withThreadPool
Sets optional thread pool for jetty server. This is useful for overriding the default thread pool behaviour for example io.dropwizard.metrics.jetty9.InstrumentedQueuedThreadPool.- Parameters:
threadPool
- thread pool- Returns:
- Builder pattern - returns this instance
-