# File lib/puppet/indirector/queue.rb, line 73 73: def self.subscribe 74: client.subscribe(queue) do |msg| 75: begin 76: yield(self.intern(msg)) 77: rescue => detail 78: puts detail.backtrace if Puppet[:trace] 79: Puppet.err "Error occured with subscription to queue %s for indirection %s: %s" % [queue, indirection_name, detail] 80: end 81: end 82: end