lib/dispatch-rider/runner.rb in dispatch-rider-0.2.6 vs lib/dispatch-rider/runner.rb in dispatch-rider-0.2.7

- old
+ new

@@ -28,24 +28,28 @@ def callbacks @callbacks ||= Callbacks::Access.new(config.callbacks) end + def logger + config.logger + end + def ready - puts "Creating subscriber..." + logger.info "Creating subscriber..." @subscriber = config.subscriber.new config.handlers.each do |handler_name| - puts "Registering #{handler_name} handler..." + logger.info "Registering #{handler_name} handler..." @subscriber.register_handler(handler_name) end end def set_queue_from_config kind = config.queue_kind info = config.queue_info - puts "Setting #{kind} queue @ #{info.to_json} ..." + logger.info "Setting #{kind} queue @ #{info.to_json} ..." @subscriber.register_queue(kind, info) @subscriber.setup_demultiplexer(kind, config.error_handler) end end