class 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