# File lib/chef/expander/vnode.rb, line 45
      def start
        @supervisor.vnode_added(self)

        subscription_confirmed = Proc.new do
          abort_on_multiple_subscribe
          supervise_consumer_count
        end

        queue.subscribe(:ack => true, :confirm => subscription_confirmed) do |headers, payload|
          log.debug {"got #{payload} size(#{payload.size} bytes) on queue #{queue_name}"}
          solrizer = Solrizer.new(payload) { headers.ack }
          solrizer.run
        end

      rescue MQ::Error => e
        log.error {"Failed to start subscriber on #{queue_name} #{e.class.name}: #{e.message}"}
      end