# 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