From b4218f07bfdc3a2dbe96675bb2269c813597bd18 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Carl=20H=C3=B6rberg?= <carl@84codes.com>
Date: Sat, 11 May 2024 01:52:18 +0200
Subject: [PATCH] close socket if client read_loop exits

---
 src/amqproxy/client.cr | 1 +
 1 file changed, 1 insertion(+)

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