Class: SharedBroker::MiddlewarePipeline

Inherits:

Object

Object
SharedBroker::MiddlewarePipeline

show all

Defined in:: lib/shared_broker/middleware_pipeline.rb

Instance Method Summary collapse

#execute(topic, message, metadata = {}, &block) ⇒ Object
#initialize(middlewares) ⇒ MiddlewarePipeline constructor

A new instance of MiddlewarePipeline.

Constructor Details

#initialize(middlewares) ⇒ `MiddlewarePipeline`

Returns a new instance of MiddlewarePipeline.



5
6
7

# File 'lib/shared_broker/middleware_pipeline.rb', line 5

def initialize(middlewares)
  @middlewares = Array(middlewares)
end

Instance Method Details

#execute(topic, message, metadata = {}, &block) ⇒ `Object`



9
10
11

# File 'lib/shared_broker/middleware_pipeline.rb', line 9

def execute(topic, message, metadata = {}, &block)
  run_middleware(0, topic, message, metadata, &block)
end