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