module Legion::Extensions::Tasker::Transport

Public Class Methods

e_to_q() click to toggle source
# 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