message_broker.rb in appfuel-service-0.2.1

- old
+ new

@@ -1,25 +1,19 @@
 Appfuel::Initialize.define('global.message_broker') do |config, container|
   unless config.key?(:sneakers)
     fail "[initializer message_broker] :sneakers not found"
   end
 
-  consumer_keys = container['message_brokers.consumer_keys']
-  unless consumer_keys.is_a?(Array)
-    fail "[initializer message_broker] message_borker.consumers must be " +
-         " an Array"
+  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])
 
 
-  consumers = consumer_keys.each.inject([]) do |result, key|
-    result << container[key]
-    result
-  end
-
-  container.register("message_brokers.runner", Sneakers::Runner.new(consumers))
+  container.register("message_brokers.runner_class", Sneakers::Runner)
   nil
 end