diff --git a/framework/src/main/java/org/toop/framework/networking/NetworkingClientManager.java b/framework/src/main/java/org/toop/framework/networking/NetworkingClientManager.java index 0f4538f..02434fc 100644 --- a/framework/src/main/java/org/toop/framework/networking/NetworkingClientManager.java +++ b/framework/src/main/java/org/toop/framework/networking/NetworkingClientManager.java @@ -34,7 +34,9 @@ public class NetworkingClientManager implements org.toop.framework.networking.in @Override public void run() { - if (networkClients.get(id) != null) { + NetworkingClient qClient = networkClients.get(id); + if (qClient != null) { + qClient.closeConnection(); networkClients.remove(id); }