From 907b39b9708cbca10446336c424754e13d55e683 Mon Sep 17 00:00:00 2001 From: Luke Kanies Date: Thu, 28 May 2009 10:10:40 -0500 Subject: 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 --- lib/puppet/util/queue/stomp.rb | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'lib/puppet/util/queue') 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) -- cgit