# File lib/chef/expander/node.rb, line 67 def attach_to_queue(queue, colloquial_name, &message_handler) queue.subscribe(:ack => true) do |headers, payload| log.debug { "received message on #{colloquial_name} queue: #{payload}" } message_handler.call(payload) headers.ack end end