# 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