diff options
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/puppet/util/queue/stomp.rb | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/lib/puppet/util/queue/stomp.rb b/lib/puppet/util/queue/stomp.rb index 62716fab2..a87268b72 100644 --- a/lib/puppet/util/queue/stomp.rb +++ b/lib/puppet/util/queue/stomp.rb @@ -33,7 +33,10 @@ class Puppet::Util::Queue::Stomp end def subscribe(target) - stomp_client.subscribe(stompify_target(target)) {|stomp_message| yield(stomp_message.body)} + stomp_client.subscribe(stompify_target(target), :ack => :client) do |stomp_message| + yield(stomp_message.body) + stomp_client.acknowledge(stomp_message) + end end def stompify_target(target) |