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/lex_register.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

Defined Under Namespace

Modules: Exchanges, Messages, Queues

Class Method Summary collapse

Class Method Details

.e_to_q ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/legion/extensions/tasker/transport.rb', line 7

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