diff options
author | Luke Kanies <luke@madstop.com> | 2009-04-14 12:59:10 -0500 |
---|---|---|
committer | James Turnbull <james@lovedthanlost.net> | 2009-04-22 14:39:39 +1000 |
commit | a705809b1e5a27062d683c138135046cc7e70ae1 (patch) | |
tree | c68b329e6b97427d26795c9a8b2b55f6af29f597 /lib/puppet | |
parent | 8a67a5c4e059398193b94a06df3f1ac6cc6f095b (diff) | |
download | puppet-a705809b1e5a27062d683c138135046cc7e70ae1.tar.gz puppet-a705809b1e5a27062d683c138135046cc7e70ae1.tar.xz puppet-a705809b1e5a27062d683c138135046cc7e70ae1.zip |
Adding defaults necessary for queueing
These are all of the defaults needed to configure queueing.
Diffstat (limited to 'lib/puppet')
-rw-r--r-- | lib/puppet/defaults.rb | 21 |
1 files changed, 19 insertions, 2 deletions
diff --git a/lib/puppet/defaults.rb b/lib/puppet/defaults.rb index 3454f02dd..ba9697411 100644 --- a/lib/puppet/defaults.rb +++ b/lib/puppet/defaults.rb @@ -163,7 +163,24 @@ module Puppet configuration files. This timeout determines how quickly Puppet checks whether a file (such as manifests or templates) has changed on disk." ], - :queue_type => ["stomp", "Which type of queue to use for asynchronous processing."] + :queue_type => ["stomp", "Which type of queue to use for asynchronous processing."], + :queue_type => ["stomp", "Which type of queue to use for asynchronous processing."], + :queue_source => ["stomp://localhost:61613/", "Which type of queue to use for asynchronous processing. If your stomp server requires + authentication, you can include it in the URI as long as your stomp client library is at least 1.1.1"], + :async_storeconfigs => {:default => false, :desc => "Whether to use a queueing system to provide asynchronous database integration. + Requires that ``puppetqd`` be running.", + :hook => proc do |value| + if value + # This reconfigures the terminii for Node, Facts, and Catalog + Puppet.settings[:storeconfigs] = true + + # But then we modify the configuration + Puppet::Node::Catalog.cache_class = :queue + else + raise "Cannot disable asynchronous storeconfigs in a running process" + end + end + } ) hostname = Facter["hostname"].value @@ -687,7 +704,7 @@ module Puppet require 'puppet/node/facts' require 'puppet/resource/catalog' if value - Puppet::Node::Catalog.cache_class = :active_record + Puppet::Node::Catalog.cache_class = :active_record unless Puppet.settings[:async_storeconfigs] Puppet::Node::Facts.cache_class = :active_record Puppet::Node.cache_class = :active_record end |