Class: KarlMalone::ConnectionBroker
- Inherits:
-
Object
- Object
- KarlMalone::ConnectionBroker
- Defined in:
- lib/karl_malone/connection_broker.rb
Instance Method Summary collapse
-
#initialize(consumers, override_settings = {}) ⇒ ConnectionBroker
constructor
A new instance of ConnectionBroker.
- #start! ⇒ Object
Constructor Details
#initialize(consumers, override_settings = {}) ⇒ ConnectionBroker
Returns a new instance of ConnectionBroker.
5 6 7 8 |
# File 'lib/karl_malone/connection_broker.rb', line 5 def initialize(consumers, override_settings={}) @consumers = consumers @override_settings = override_settings end |
Instance Method Details
#start! ⇒ Object
10 11 12 13 14 15 16 |
# File 'lib/karl_malone/connection_broker.rb', line 10 def start! AMQP.start(connection_settings) do |connection| consumers.each do |consumer| consumer.start!(connection) end end end |