Class: MagicPipe::Transports::Multi

Inherits:
Base
  • Object
show all
Defined in:
lib/magic_pipe/transports/multi.rb

Instance Attribute Summary

Attributes inherited from Base

#logger, #metrics

Instance Method Summary collapse

Constructor Details

#initialize(config, metrics) ⇒ Multi

Returns a new instance of Multi.



6
7
8
9
 
# File 'lib/magic_pipe/transports/multi.rb', line 6

def initialize(config, metrics)
  super(config, metrics)
  @transports = build_nested_transports
end

Instance Method Details

#submit!(payload, metadata) ⇒ Object 



12
13
14
15
16
17
18
19
20
 
# File 'lib/magic_pipe/transports/multi.rb', line 12

def submit!(payload, metadata)
  @transports.map do |transport|
    begin
      transport.submit!(payload, metadata)
    rescue => e
      log_error(e, transport)
    end
  end
end