# 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