Sha256: afef6671b71f1e1971379f03f3b6490bc8ec0979f8b0ea8c058d64f577de3f7b
Contents?: true
Size: 289 Bytes
Versions: 13
Compression:
Stored size: 289 Bytes
Contents
# frozen_string_literal: true
require "bunny/channel"
class Bunny::Channel
module RabbitExtensions
def handle_basic_return(*)
@unconfirmed_set_mutex.synchronize { @only_acks_received = false } # fails confirm_select
super
end
end
prepend(RabbitExtensions)
end
Version data entries
13 entries across 13 versions & 1 rubygems