lib/legion/transport/queue.rb in legion-transport-1.1.9 vs lib/legion/transport/queue.rb in legion-transport-1.2.0
- old
+ new
@@ -12,10 +12,10 @@
recreate_queue(queue)
retry
end
def recreate_queue(queue)
- Legion::Logging.warn "Queue:#{queue} exists with wrong parameters, deleting and creating"
+ Legion::Transport.logger.warn "Queue:#{queue} exists with wrong parameters, deleting and creating"
queue = ::Bunny::Queue.new(Legion::Transport::Connection.channel, queue, no_declare: true, passive: true)
queue.delete(if_empty: true)
end
def default_options