diff --git a/neo/storage/replicator.py b/neo/storage/replicator.py
index 6c47c7fba2ac560311557019f8fd3f05b8a5b356..cc178526a530221996b50a6aa3ae3745e67d482d 100644
--- a/neo/storage/replicator.py
+++ b/neo/storage/replicator.py
@@ -232,6 +232,9 @@ class Replicator(object):
         except KeyError:
             pass
         self.current_partition = None
+        if not self.pending():
+            self.current_connection.close()
+            self.current_connection = None
 
     def act(self):
         # If the new partition list is not empty, I must ask a critical