Module: Legion::Extensions::Tasker::Transport

Extended by:
Legion::Extensions::Transport
Defined in:
lib/legion/extensions/tasker/transport.rb,
lib/legion/extensions/tasker/transport/exchanges/task.rb,
lib/legion/extensions/tasker/transport/queues/subtask.rb,
lib/legion/extensions/tasker/transport/queues/updater.rb,
lib/legion/extensions/tasker/transport/queues/task_log.rb,
lib/legion/extensions/tasker/transport/queues/check_subtask.rb,
lib/legion/extensions/tasker/transport/queues/fetch_delayed.rb,
lib/legion/extensions/tasker/transport/queues/task_mananger.rb,
lib/legion/extensions/tasker/transport/messages/fetch_delayed.rb

Defined Under Namespace

Modules: Exchanges, Messages, Queues

Class Method Summary collapse

Class Method Details

.e_to_q ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/legion/extensions/tasker/transport.rb', line 12

def self.e_to_q
  [
    {
      to:          'updater',
      routing_key: 'task.update'
    },
    {
      to:          'log',
      routing_key: 'task.logs.#'
    }, {
      to:          'check_subtask',
      routing_key: 'task.subtask.check'
    }, {
      to:          'fetch_delayed',
      routing_key: 'fetch.delayed'
    }, {
      from:        'tasker',
      to:          'task_manager',
      routing_key: 'task.task_manager.#'
    }
  ]
end