diff --git a/src/amqproxy/client.cr b/src/amqproxy/client.cr
index 400639b..b7c718a 100644
--- a/src/amqproxy/client.cr
+++ b/src/amqproxy/client.cr
@@ -126,6 +126,7 @@ module AMQProxy
       Log.debug { "Disconnected" }
     ensure
       @outgoing_frames.close
+      socket.close rescue nil
       close_all_upstream_channels
     end