Package spark.embeddedserver.jetty
Class EmbeddedJettyServer
- java.lang.Object
-
- spark.embeddedserver.jetty.EmbeddedJettyServer
-
- All Implemented Interfaces:
EmbeddedServer
public class EmbeddedJettyServer extends java.lang.Object implements EmbeddedServer
Spark server implementation
-
-
Field Summary
Fields Modifier and Type Field Description private org.eclipse.jetty.server.Handler
handler
private org.slf4j.Logger
logger
private static java.lang.String
NAME
private org.eclipse.jetty.server.Server
server
private JettyServerFactory
serverFactory
private static int
SPARK_DEFAULT_PORT
private org.eclipse.jetty.util.thread.ThreadPool
threadPool
private java.util.Map<java.lang.String,WebSocketHandlerWrapper>
webSocketHandlers
private java.util.Optional<java.lang.Integer>
webSocketIdleTimeoutMillis
-
Constructor Summary
Constructors Constructor Description EmbeddedJettyServer(JettyServerFactory serverFactory, org.eclipse.jetty.server.Handler handler)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
activeThreadCount()
void
configureWebSockets(java.util.Map<java.lang.String,WebSocketHandlerWrapper> webSocketHandlers, java.util.Optional<java.lang.Integer> webSocketIdleTimeoutMillis)
Configures the web sockets for the embedded server.void
extinguish()
Extinguish the embedded server.int
ignite(java.lang.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).EmbeddedJettyServer
withThreadPool(org.eclipse.jetty.util.thread.ThreadPool threadPool)
Sets optional thread pool for jetty server.
-
-
-
Field Detail
-
SPARK_DEFAULT_PORT
private static final int SPARK_DEFAULT_PORT
- See Also:
- Constant Field Values
-
NAME
private static final java.lang.String NAME
- See Also:
- Constant Field Values
-
serverFactory
private final JettyServerFactory 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
private java.util.Map<java.lang.String,WebSocketHandlerWrapper> webSocketHandlers
-
webSocketIdleTimeoutMillis
private java.util.Optional<java.lang.Integer> webSocketIdleTimeoutMillis
-
threadPool
private org.eclipse.jetty.util.thread.ThreadPool threadPool
-
-
Constructor Detail
-
EmbeddedJettyServer
public EmbeddedJettyServer(JettyServerFactory serverFactory, org.eclipse.jetty.server.Handler handler)
-
-
Method Detail
-
configureWebSockets
public void configureWebSockets(java.util.Map<java.lang.String,WebSocketHandlerWrapper> webSocketHandlers, java.util.Optional<java.lang.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(java.lang.String host, int port, SslStores sslStores, int maxThreads, int minThreads, int threadIdleTimeoutMillis) throws java.lang.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:
java.lang.Exception
-
join
public void join() throws java.lang.InterruptedException
Joins the embedded server thread(s).- Specified by:
join
in interfaceEmbeddedServer
- Throws:
java.lang.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
public EmbeddedJettyServer withThreadPool(org.eclipse.jetty.util.thread.ThreadPool threadPool)
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
-
-