    # 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