diff options
Diffstat (limited to 'src/main/java/derms/net/rmulticast')
| -rw-r--r-- | src/main/java/derms/net/rmulticast/ReliableMulticast.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/main/java/derms/net/rmulticast/ReliableMulticast.java b/src/main/java/derms/net/rmulticast/ReliableMulticast.java index 3894021..c23baaa 100644 --- a/src/main/java/derms/net/rmulticast/ReliableMulticast.java +++ b/src/main/java/derms/net/rmulticast/ReliableMulticast.java @@ -63,7 +63,7 @@ public class ReliableMulticast<T extends MessagePayload> { public void close() { log.info("Shutting down..."); - ThreadPool.shutDown(pool, log); + ThreadPool.shutdownNow(pool, log); outSock.close(); log.info("Finished shutting down."); } |