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