Skip to content

Commit 525128e

Browse files
committed
Lint
1 parent 1794421 commit 525128e

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/amqproxy/upstream.cr

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -204,7 +204,7 @@ module AMQProxy
204204
case tune = AMQ::Protocol::Frame.from_io(@socket)
205205
when AMQ::Protocol::Frame::Connection::Tune
206206
server_max = tune.channel_max.zero? ? UInt16::MAX : tune.channel_max
207-
max_upstream_channels = @max_upstream_channels.zero? ? UInt16::MAX : @max_upstream_channels
207+
max_upstream_channels = @max_upstream_channels.zero? ? UInt16::MAX : @max_upstream_channels
208208
channel_max = Math.min(server_max, max_upstream_channels)
209209
frame_max = tune.frame_max.zero? ? 131072_u32 : Math.min(131072_u32, tune.frame_max)
210210
tune_ok = AMQ::Protocol::Frame::Connection::TuneOk.new(channel_max, frame_max, tune.heartbeat)

0 commit comments

Comments
 (0)