We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4b06493 commit 574805cCopy full SHA for 574805c
src/amqproxy/upstream.cr
@@ -117,12 +117,12 @@ module AMQProxy
117
clients = Set(Client).new
118
@channels_lock.synchronize do
119
return if @channels.empty?
120
+ Log.debug { "Upstream connection closed, closing #{@channels.size} client connections" }
121
@channels.each_value do |downstream_connection|
122
clients << downstream_connection.client
123
end
124
125
clients.each do |client|
- Log.debug { "Closing client connection due to upstream failure." }
126
client.close_connection(code, reason)
127
128
@channels.clear
0 commit comments