Calling socketHandlerThread.interrupt() on TcpTransportServer stop to
make sure the broker shutsdown cleanly.

Patch applied with thanks to Erik Godding Boye
This commit is contained in:
Christopher L. Shannon (cshannon) 2015-10-08 12:11:16 +00:00
parent 6fef9eea65
commit 4adc8e4f4e
1 changed files with 4 additions and 0 deletions

View File

@ -467,6 +467,10 @@ public class TcpTransportServer extends TransportServerThreadSupport implements
serverSocket.close();
serverSocket = null;
}
if (socketHandlerThread != null) {
socketHandlerThread.interrupt();
socketHandlerThread = null;
}
super.doStop(stopper);
}