Module: Legion::Extensions::Transformer::Transport

Defined in:
lib/legion/extensions/transformer/transport.rb,
lib/legion/extensions/transformer/transport/exchanges/task.rb,
lib/legion/extensions/transformer/transport/messages/message.rb,
lib/legion/extensions/transformer/transport/queues/transform.rb

Defined Under Namespace

Modules: Exchanges, Messages, Queues

Class Method Summary collapse

Class Method Details

.additional_e_to_q ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/legion/extensions/transformer/transport.rb', line 18

def self.additional_e_to_q
  [
    {
      to:          Legion::Extensions::Transformer::Transport::Queues::Transform,
      routing_key: 'task.conditioner.succeeded'
    }, {
      to:          Legion::Extensions::Transformer::Transport::Queues::Transform,
      routing_key: 'task.subtask.transform'
    }
  ]
end

.build ⇒ Object 



7
8
9
10
11
12
13
14
15
16
 
# File 'lib/legion/extensions/transformer/transport.rb', line 7

def self.build
  unless @_extended
    return unless defined?(::Legion::Extensions::Transport)

    extend ::Legion::Extensions::Transport

    @_extended = true
  end
  Legion::Extensions::Transport.instance_method(:build).bind_call(self)
end