Contents

require 'legion/transport/exchanges/task'
require 'legion/extensions/transport'

module Legion::Extensions::Tasker
  module Transport
    extend Legion::Extensions::Transport
    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'
        }
      ]
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
lex-tasker-0.1.3	lib/legion/extensions/tasker/transport.rb
lex-tasker-0.1.2	lib/legion/extensions/tasker/transport.rb
lex-tasker-0.1.1	lib/legion/extensions/tasker/transport.rb