Skip to content

Commit

Permalink
fixup! Support for passing Connection::Blocked frames to downstream c…
Browse files Browse the repository at this point in the history
…lients
  • Loading branch information
carlhoerberg committed Mar 6, 2024
1 parent 9aa5691 commit c5d05bc
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions src/amqproxy/upstream.cr
Original file line number Diff line number Diff line change
Expand Up @@ -135,12 +135,14 @@ module AMQProxy
end
end

private def send_to_all_clients(frame : AMQ::Protocol::Frames::Connection)
private def send_to_all_clients(frame : AMQ::Protocol::Frame::Connection)
Log.debug { "Sending broadcast frame to all client connections" }
clients = Set(Client).new
@channels_lock.synchronize do
@channels.each_value do |downstream_channel|
clients << downstream_channel.client
if dc = downstream_channel
clients << dc.client
end
end
end
clients.each do |client|
Expand Down

0 comments on commit c5d05bc

Please sign in to comment.