class Legion::Extensions::Tasker::Transport::Queues::FetchDelayed

Public Instance Methods

queue_name() click to toggle source
# File lib/legion/extensions/tasker/transport/queues/fetch_delayed.rb, line 5
def queue_name
  'task.fetch_delayed'
end
queue_options() click to toggle source
# File lib/legion/extensions/tasker/transport/queues/fetch_delayed.rb, line 9
def queue_options
  {
    arguments: {
      'x-single-active-consumer': true,
      'x-max-priority':           255,
      'x-message-ttl':            1
    }
  }
end