Module: Legion::Extensions::Synapse::Transport

Extended by:: Transport

Defined in:: lib/legion/extensions/synapse/transport.rb,
lib/legion/extensions/synapse/transport/queues/pain.rb,
lib/legion/extensions/synapse/transport/messages/pain.rb,
lib/legion/extensions/synapse/transport/messages/signal.rb,
lib/legion/extensions/synapse/transport/queues/evaluate.rb,
lib/legion/extensions/synapse/transport/exchanges/synapse.rb

Defined Under Namespace

Modules: Exchanges, Messages, Queues

Class Method Summary collapse

.additional_e_to_q ⇒ Object

Class Method Details

.additional_e_to_q ⇒ `Object`

# File 'lib/legion/extensions/synapse/transport.rb', line 9

def self.additional_e_to_q
  [
    { from: 'synapse', to: 'evaluate', routing_key: 'synapse.evaluate' },
    { from: 'task', to: 'pain', routing_key: 'task.failed' }
  ]
end