Sha256: 833601e23ba4ecd9323cca031b33fb5a19191b70c89b216ea860a07f9e25280f
Contents?: true
Size: 519 Bytes
Versions: 10
Compression:
Stored size: 519 Bytes
Contents
Appfuel::Initialize.define('global.message_broker') do |config, container|
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 " +
"must be an Array"
end
require 'sneakers'
require 'sneakers/runner'
Sneakers.configure(config[:sneakers])
container.register("message_brokers.runner_class", Sneakers::Runner)
nil
end
Version data entries
10 entries across 10 versions & 1 rubygems