Skip to content

Commit

Permalink
fixup! On channel error, correctly send close-ok from client to upstream
Browse files Browse the repository at this point in the history
  • Loading branch information
carlhoerberg committed Mar 9, 2024
1 parent 2d02fd2 commit 91e7e40
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/amqproxy/upstream.cr
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ module AMQProxy
end

# Frames from upstream (to client)
private def read_loop(socket, remote_address : String) # ameba:disable Metrics/CyclomaticComplexity
private def read_loop(socket, remote_address : String)
Log.context.set(remote_address: remote_address)
loop do
case frame = AMQ::Protocol::Frame.from_io(socket, IO::ByteFormat::NetworkEndian)
Expand Down

0 comments on commit 91e7e40

Please sign in to comment.