Skip to content

Commit

Permalink
Merge branch 're-gmbh-main'
Browse files Browse the repository at this point in the history
  • Loading branch information
michaelklishin committed Dec 19, 2022
2 parents a2f3e10 + 108383a commit e59ad79
Showing 1 changed file with 6 additions and 2 deletions.
8 changes: 6 additions & 2 deletions lib/bunny/session.rb
Original file line number Diff line number Diff line change
Expand Up @@ -671,8 +671,12 @@ def handle_frame(ch_number, method)
# avoid doing that while holding a mutex lock. MK.
ch.handle_method(method)
ensure
# synchronises on @channel_mutex under the hood
self.unregister_channel(ch)
if ch.nil?
@logger.warn "Received a server-sent channel.close but the channel was not found locally. Ignoring the frame."
else
# synchronises on @channel_mutex under the hood
self.unregister_channel(ch)
end
end
when AMQ::Protocol::Basic::GetEmpty then
ch = find_channel(ch_number)
Expand Down

0 comments on commit e59ad79

Please sign in to comment.