diff options
| author | Luke Kanies <luke@madstop.com> | 2009-05-28 10:10:40 -0500 |
|---|---|---|
| committer | James Turnbull <james@lovedthanlost.net> | 2009-06-03 07:32:21 +1000 |
| commit | 907b39b9708cbca10446336c424754e13d55e683 (patch) | |
| tree | 9c56aa19d873d4aa6cd845e35c8ac2197c93fc4c /lib/puppet | |
| parent | 42247f0f5d08bce4d3fd2b020b770a12cc2f91db (diff) | |
| download | puppet-907b39b9708cbca10446336c424754e13d55e683.tar.gz puppet-907b39b9708cbca10446336c424754e13d55e683.tar.xz puppet-907b39b9708cbca10446336c424754e13d55e683.zip | |
Using Message acknowledgement in queueing
This allows a more fine-grained load-balancing
of the queue, which makes it easy to spin up
multiple puppetqd instances and process the
queues faster.
Signed-off-by: Luke Kanies <luke@madstop.com>
Diffstat (limited to 'lib/puppet')
| -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) |