lib/dispatch-rider/configuration.rb in dispatch-rider-1.6.1 vs lib/dispatch-rider/configuration.rb in dispatch-rider-1.6.2
- old
+ new
@@ -1,17 +1,28 @@
module DispatchRider
class Configuration
- attr_accessor :handler_path, :error_handler, :queue_info, :queue_kind, :subscriber, :logger, :log_formatter, :debug
+ attr_accessor(
+ :handler_path,
+ :error_handler,
+ :queue_info,
+ :queue_kind,
+ :subscriber,
+ :logger,
+ :log_formatter,
+ :debug,
+ :additional_info_injector
+ )
attr_reader :callbacks
def initialize
@handler_path = Dir.getwd + "/app/handlers"
@error_handler = DispatchRider::DefaultErrorHandler
@queue_kind = :file_system
@queue_info = { path: "tmp/dispatch-rider-queue" }
@callbacks = Callbacks::Storage.new
@subscriber = DispatchRider::Subscriber
@log_formatter = DispatchRider::Logging::TextFormatter.new
+ @additional_info_injector = -> (data) { data }
@logger = Logger.new(STDERR)
@debug = false
@callbacks.around(:dispatch_message) do |job, message|
Logging::LifecycleLogger.wrap_handling(message) do