lib/activehook/server/manager.rb in activehook-server-0.1.5 vs lib/activehook/server/manager.rb in activehook-server-0.1.6
- old
+ new
@@ -46,12 +46,12 @@
end
# Information about the start process
#
def start_messages
- ActiveHook::Server.log.info("* Workers: #{@workers}")
- ActiveHook::Server.log.info("* Threads: #{@options[:queue_threads]} queue, #{@options[:retry_threads]} retry")
+ Server.log.info("* Workers: #{@workers}")
+ Server.log.info("* Threads: #{@options[:queue_threads]} queue, #{@options[:retry_threads]} retry")
end
# Validates our data before starting our Workers. Also instantiates our
# connection pool by pinging Redis.
#
@@ -60,20 +60,17 @@
validate_workers
validate_options
end
def validate_redis
- ActiveHook::Server.redis.with { |c| c.ping && c.quit }
+ Server.redis.with { |c| c.ping && c.quit }
rescue
- msg = 'Cound not connect to Redis.'
- ActiveHook::Server.log.err(msg)
- raise Errors::Manager, msg
+ raise Errors::Manager, 'Cound not connect to Redis.'
end
def validate_workers
return if @workers.is_a?(Integer)
- msg = 'Workers must be an Integer.'
- raise Errors::Manager, msg
+ raise Errors::Manager, 'Workers must be an Integer.'
end
def validate_options
return if @options.is_a?(Hash)
raise Errors::Manager, 'Options must be a Hash.'