lib/appfuel/service/initializers/message_broker.rb in appfuel-service-0.3.3 vs lib/appfuel/service/initializers/message_broker.rb in appfuel-service-0.3.4
- old
+ new
@@ -2,18 +2,21 @@
unless config.key?(:sneakers)
fail "[initializer message_broker] :sneakers not found"
end
unless container['message_brokers.consumer_keys'].is_a?(Array)
- fail "[initializer message_broker] message_borker.consumer_keys " +
+ fail "[initializer message_broker] message_broker.consumer_keys " +
"must be an Array"
end
require 'sneakers'
require 'sneakers/runner'
require 'sneakers/handlers/maxretry'
- Sneakers.configure(config[:sneakers])
+ settings = config[:sneakers]
+ settings[:log] = settings.delete(:logfile)
+
+ Sneakers.configure(settings)
container.register("message_brokers.runner_class", Sneakers::Runner)
nil
end