# File lib/puppet/util/queue/stomp.rb, line 35 35: def subscribe(target) 36: stomp_client.subscribe(stompify_target(target), :ack => :client) do |stomp_message| 37: yield(stomp_message.body) 38: stomp_client.acknowledge(stomp_message) 39: end 40: end