close upstream channel on channel errors

cloudamqp · May 6, 2024 · 6ea3c69 · 6ea3c69
1 parent 6f57fdc
commit 6ea3c69
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/amqproxy/upstream.cr b/src/amqproxy/upstream.cr
@@ -93,6 +93,9 @@ module AMQProxy
         when AMQ::Protocol::Frame::Channel::OpenOk  # we assume it always succeeds
         when AMQ::Protocol::Frame::Channel::CloseOk # when channel pool requested channel close
         else
+          if frame.is_a? AMQ::Protocol::Frame::Channel::Close
+            @unsafe_channels.add(frame.channel)
+          end
           if downstream_channel = @channels[frame.channel]?
             downstream_channel.write(frame)
           else