diff --git a/src/main/java/com/google/code/gossip/manager/GossipManager.java b/src/main/java/com/google/code/gossip/manager/GossipManager.java index f3ee91b..99aef68 100644 --- a/src/main/java/com/google/code/gossip/manager/GossipManager.java +++ b/src/main/java/com/google/code/gossip/manager/GossipManager.java @@ -188,8 +188,12 @@ public abstract class GossipManager extends Thread implements NotificationListen public void shutdown() { _gossipServiceRunning.set(false); _gossipThreadExecutor.shutdown(); - passiveGossipThread.shutdown(); - activeGossipThread.shutdown(); + if (passiveGossipThread != null){ + passiveGossipThread.shutdown(); + } + if (activeGossipThread != null){ + activeGossipThread.shutdown(); + } try { boolean result = _gossipThreadExecutor.awaitTermination(1000, TimeUnit.MILLISECONDS); if (!result){