mirror of
https://github.com/jetty/jetty.project.git
synced 2025-03-04 12:59:30 +00:00
416577 enhanced shutdown handler to send shutdown at startup
This commit is contained in:
parent
ba5a709245
commit
3acda280a8
@ -55,6 +55,8 @@ public abstract class AbstractHandler extends ContainerLifeCycle implements Hand
|
||||
protected void doStart() throws Exception
|
||||
{
|
||||
LOG.debug("starting {}",this);
|
||||
if (_server==null)
|
||||
LOG.warn("No Server set for {}",this);
|
||||
super.doStart();
|
||||
}
|
||||
|
||||
|
@ -189,6 +189,7 @@ public class ShutdownHandler extends HandlerWrapper
|
||||
|
||||
LOG.info("Shutting down by request from " + getRemoteAddr(request));
|
||||
|
||||
final Server server=getServer();
|
||||
new Thread()
|
||||
{
|
||||
@Override
|
||||
@ -196,7 +197,7 @@ public class ShutdownHandler extends HandlerWrapper
|
||||
{
|
||||
try
|
||||
{
|
||||
shutdownServer();
|
||||
shutdownServer(server);
|
||||
}
|
||||
catch (InterruptedException e)
|
||||
{
|
||||
@ -227,9 +228,9 @@ public class ShutdownHandler extends HandlerWrapper
|
||||
return _shutdownToken.equals(tok);
|
||||
}
|
||||
|
||||
private void shutdownServer() throws Exception
|
||||
private void shutdownServer(Server server) throws Exception
|
||||
{
|
||||
getServer().stop();
|
||||
server.stop();
|
||||
|
||||
if (_exitJvm)
|
||||
{
|
||||
|
@ -51,8 +51,9 @@ public class ShutdownHandlerTest
|
||||
public void startServer() throws Exception
|
||||
{
|
||||
MockitoAnnotations.initMocks(this);
|
||||
shutdownHandler = new ShutdownHandler(shutdownToken);
|
||||
server.setHandler(shutdownHandler);
|
||||
server.start();
|
||||
shutdownHandler = new ShutdownHandler(server,shutdownToken);
|
||||
}
|
||||
|
||||
@Test
|
||||
|
Loading…
x
Reference in New Issue
Block a user