From 27d73e3f891e4ccfde3a50f341ded666823b1cdc Mon Sep 17 00:00:00 2001 From: Steve Kemp Date: Wed, 21 Jan 2015 16:49:43 +0000 Subject: Don't hard-wire redis as the queue-type. Read it from the configuration-file and don't expose the server flag which is now bogus. --- bin/custodian-enqueue | 16 ++++------------ 1 file changed, 4 insertions(+), 12 deletions(-) (limited to 'bin/custodian-enqueue') diff --git a/bin/custodian-enqueue b/bin/custodian-enqueue index 20654c1..672ace9 100755 --- a/bin/custodian-enqueue +++ b/bin/custodian-enqueue @@ -68,17 +68,10 @@ if __FILE__ == $0 then $help = false $manual = false - # - # The beanstalkd server address. - # - settings = Custodian::Settings.instance() - $SERVER = settings.queue_server - begin opts = GetoptLong.new( [ "--dump", "-d", GetoptLong::NO_ARGUMENT ], [ "--test", GetoptLong::NO_ARGUMENT ], - [ "--server", GetoptLong::REQUIRED_ARGUMENT ], [ "--file", "-f", GetoptLong::REQUIRED_ARGUMENT ], [ "--help", "-h", GetoptLong::NO_ARGUMENT ], [ "--manual","-m", GetoptLong::NO_ARGUMENT ] @@ -89,8 +82,6 @@ if __FILE__ == $0 then ENV["DUMP"] = "1" when "--test" then ENV["TEST"] = "1" - when "--server" then - $SERVER = arg when "--file" then ENV["FILE"] = arg when "--help" then @@ -136,11 +127,12 @@ if __FILE__ == $0 then # - # Connected to the server + # Connected to the queue - be it redis or beanstalkd # - queue = Custodian::QueueType.create( "redis" ) + settings = Custodian::Settings.instance() + queue = Custodian::QueueType.create( settings.queue_type() ) if ( ! queue ) - puts "Failed to connect to beanstalk server: #{$SERVER}" + puts "Failed to connect to the #{settings.queue_type()} queue" exit 1 end -- cgit v1.2.1