class Qyu::Queue::Base

Qyu::Queue::Base

Public Class Methods

valid_config?(_config) click to toggle source

This class acts as an interface for any queue adapter implemented for Qyu Implement the following methods in any queue and it should work seemlessly

# File lib/qyu/queue/base.rb, line 9
def self.valid_config?(_config)
  fail Qyu::Errors::NotImplementedError
end

Public Instance Methods

acknowledge_message(_queue_name, _message_id) click to toggle source
# File lib/qyu/queue/base.rb, line 33
def acknowledge_message(_queue_name, _message_id)
  fail Qyu::Errors::NotImplementedError
end
enqueue_task(_queue_name, _task_id) click to toggle source

Instance methods to override

# File lib/qyu/queue/base.rb, line 21
def enqueue_task(_queue_name, _task_id)
  fail Qyu::Errors::NotImplementedError
end
enqueue_task_to_failed_queue(_queue_name, _task_id) click to toggle source
# File lib/qyu/queue/base.rb, line 25
def enqueue_task_to_failed_queue(_queue_name, _task_id)
  fail Qyu::Errors::NotImplementedError
end
enqueue_tasks(queue_name, task_ids) click to toggle source

Instance methods

# File lib/qyu/queue/base.rb, line 14
def enqueue_tasks(queue_name, task_ids)
  task_ids.each do |task_id|
    enqueue_task(queue_name, task_id)
  end
end
fetch_next_message(_queue_name) click to toggle source
# File lib/qyu/queue/base.rb, line 29
def fetch_next_message(_queue_name)
  fail Qyu::Errors::NotImplementedError
end
queues() click to toggle source
# File lib/qyu/queue/base.rb, line 37
def queues
  fail Qyu::Errors::NotImplementedError
end
size(_queue_name) click to toggle source
# File lib/qyu/queue/base.rb, line 41
def size(_queue_name)
  fail Qyu::Errors::NotImplementedError
end