Method: MessageBus::Rack::Middleware#initialize

Defined in:
lib/message_bus/rack/middleware.rb

#initialize(app, config = {}) ⇒ Middleware

Returns a new instance of Middleware.



35
36
37
38
39
40
 
# File 'lib/message_bus/rack/middleware.rb', line 35

def initialize(app, config = {})
  @app = app
  @bus = config[:message_bus] || MessageBus
  @connection_manager = MessageBus::ConnectionManager.new(@bus)
  self.start_listener
end