diff --git a/postgres_mitm.py b/postgres_mitm.py
index b16b6d8..7c26d5c 100644
--- a/postgres_mitm.py
+++ b/postgres_mitm.py
@@ -369,9 +369,7 @@ class ClientConnection(threading.Thread):
             if not sock:
                 continue
             try:
-                if not socket_is_closed(self.socket):
-                    self.socket.shutdown(socket.SHUT_RDWR)
-                self.socket.close()
+                sock.close()
             except:
                 _logger.exception('Got exception when trying to close socket')
         self.stop()