attr_accessor :mode
- attr_reader :topicprefix, :daemonize, :pluginconf, :libdir, :configured
+ attr_reader :daemonize, :pluginconf, :libdir, :configured
attr_reader :logfile, :keeplogs, :max_log_size, :loglevel, :logfacility
attr_reader :identity, :daemonize, :connector, :securityprovider, :factsource
- attr_reader :registration, :registerinterval, :topicsep, :classesfile
+ attr_reader :registration, :registerinterval, :classesfile
attr_reader :rpcauditprovider, :rpcaudit, :configdir, :rpcauthprovider
attr_reader :rpcauthorization, :color, :configfile, :rpchelptemplate
attr_reader :rpclimitmethod, :logger_type, :fact_cache_time, :collectives
attr_reader :main_collective, :ssl_cipher, :registration_collective
attr_reader :direct_addressing, :direct_addressing_threshold, :ttl, :helptemplatedir
- attr_reader :queueprefix, :default_discovery_method, :default_discovery_options
+ attr_reader :default_discovery_method, :default_discovery_options
def initialize
@configured = false
set_config_defaults(configfile)
if File.exists?(configfile)
- File.open(configfile, "r").each do |line|
+ File.readlines(configfile).each do |line|
# strip blank spaces, tabs etc off the end of all lines
line.gsub!(/\s*$/, "")
val = $2
case key
- when "topicsep"
- @topicsep = val
when "registration"
@registration = val.capitalize
when "registration_collective"
@collectives = val.split(",").map {|c| c.strip}
when "main_collective"
@main_collective = val
- when "topicprefix"
- @topicprefix = val
- when "queueprefix"
- @queueprefix = val
when "logfile"
@logfile = val
when "keeplogs"
when "identity"
@identity = val
when "direct_addressing"
- val =~ /^1|y/i ? @direct_addressing = true : @direct_addressing = false
+ @direct_addressing = false unless val =~ /^1|y/i
when "direct_addressing_threshold"
@direct_addressing_threshold = val.to_i
when "color"
end
end
+ raise('The %s config file does not specify a libdir setting, cannot continue' % configfile) if @libdir.empty?
+
I18n.load_path = Dir[File.expand_path(File.join(File.dirname(__FILE__), "locales", "*.yml"))]
I18n.locale = :en
@registration = "Agentlist"
@registerinterval = 0
@registration_collective = nil
- @topicsep = "."
- @topicprefix = "/topic/"
- @queueprefix = "/queue/"
@classesfile = "/var/lib/puppet/state/classes.txt"
@rpcaudit = false
@rpcauditprovider = ""
@collectives = ["mcollective"]
@main_collective = @collectives.first
@ssl_cipher = "aes-256-cbc"
- @direct_addressing = false
+ @direct_addressing = true
@direct_addressing_threshold = 10
@default_discovery_method = "mc"
@default_discovery_options = []