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)