lib/legion/transport/queue.rb in legion-transport-1.1.3 vs lib/legion/transport/queue.rb in legion-transport-1.1.4
- old
+ new
@@ -5,11 +5,11 @@
def initialize(queue = queue_name, options = {})
retries ||= 0
@options = options
super(channel, queue, options_builder(default_options, queue_options, options))
- rescue ::Bunny::PreconditionFailed
+ rescue Legion::Transport::CONNECTOR::PreconditionFailed
retries.zero? ? retries = 1 : raise
recreate_queue(channel, queue)
retry
end
@@ -49,10 +49,10 @@
end
def delete(options = { if_unused: true, if_empty: true })
super(options)
true
- rescue ::Bunny::PreconditionFailed
+ rescue Legion::Transport::CONNECTOR::PreconditionFailed
false
end
def acknowledge(delivery_tag)
channel.acknowledge(delivery_tag)