# File lib/chef/index_queue/consumer.rb, line 41 def run Chef::Log.debug("Starting Index Queue Consumer") AmqpClient.instance.queue # triggers connection setup begin AmqpClient.instance.queue.subscribe(:ack => true, :timeout => false) do |message| call_action_for_message(message) end rescue Bunny::ConnectionError, Errno::ECONNRESET, Bunny::ServerDownError AmqpClient.instance.disconnected! Chef::Log.warn "Connection to rabbitmq lost. attempting to reconnect" sleep 1 retry end end