Don't raise on Upstream Channel Close

cloudamqp · May 9, 2024 · ddf7368 · ddf7368
1 parent c993ae7
commit ddf7368
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/src/amqproxy/upstream.cr b/src/amqproxy/upstream.cr
@@ -48,12 +48,11 @@ module AMQProxy
     end
 
     def unassign_channel(channel : UInt16)
-      @channels_lock.synchronize do
-        if @channels.has_key? channel
-          send AMQ::Protocol::Frame::Channel::Close.new(channel, 0u16, "", 0u16, 0u16)
-          @channels.delete channel
-        end
+      if @channels_lock.synchronize { @channels.delete(channel) }
+        send AMQ::Protocol::Frame::Channel::Close.new(channel, 0u16, "", 0u16, 0u16)
       end
+    rescue ex : IO::Error | OpenSSL::SSL::Error
+      Log.debug(exception: ex) { "Error while closing upstream channel #{id}" }
     end
 
     def channels