fixups

src/amqproxy/client.cr

@@ -6,6 +6,7 @@ require "./records"
 
 module AMQProxy
   class Client
+    Log = ::Log.for(self)
     getter credentials : Credentials
     @channel_map = Hash(UInt16, UpstreamChannel).new
     @outgoing_frames = Channel(AMQ::Protocol::Frame).new(128)
@@ -58,7 +59,7 @@ module AMQProxy
           end
         end
       end
-    rescue ex : IO::Error | OpenSSL::SSL::Error
+    rescue ex : IO::Error
       raise Error.new("Client disconnected", ex) unless socket.closed?
     ensure
       @outgoing_frames.close
@@ -72,7 +73,7 @@ module AMQProxy
 
         break if frame.is_a? AMQ::Protocol::Frame::Connection::CloseOk
       end
-    rescue ex : IO::Error | OpenSSL::SSL::Error
+    rescue ex : IO::Error
       raise ex unless socket.closed?
     ensure
       @outgoing_frames.close

src/amqproxy/upstream.cr

@@ -113,6 +113,7 @@ module AMQProxy
     end
 
     private def close_all_client_channels
+      Log.debug { "Closing all client channels for closed upstream" }
       @channels_lock.synchronize do
         @channels.each_value do |downstream_channel|
           downstream_channel.try &.close