no need to raise a node disconnected if the transport service is stopped

This commit is contained in:
Shay Banon 2012-01-08 23:52:19 +02:00
parent bb1b46431c
commit 39e41ab819
1 changed files with 3 additions and 0 deletions

View File

@ -287,6 +287,9 @@ public class TransportService extends AbstractLifecycleComponent<TransportServic
@Override
public void raiseNodeDisconnected(final DiscoveryNode node) {
if (lifecycle.stoppedOrClosed()) {
return;
}
threadPool.cached().execute(new Runnable() {
@Override
public void run() {