class Shoryuken::Polling::BaseStrategy

Public Instance Methods

==(other) click to toggle source
# File lib/shoryuken/polling/base.rb, line 49
def ==(other)
  case other
  when Array
    @queues == other
  else
    if other.respond_to?(:active_queues)
      active_queues == other.active_queues
    else
      false
    end
  end
end
active_queues() click to toggle source
# File lib/shoryuken/polling/base.rb, line 45
def active_queues
  fail NotImplementedError
end
delay() click to toggle source
# File lib/shoryuken/polling/base.rb, line 62
def delay
  @delay || Shoryuken.options[:delay].to_f
end
message_processed(_queue) click to toggle source
# File lib/shoryuken/polling/base.rb, line 43
def message_processed(_queue); end
messages_found(_queue, _messages_found) click to toggle source
# File lib/shoryuken/polling/base.rb, line 39
def messages_found(_queue, _messages_found)
  fail NotImplementedError
end
next_queue() click to toggle source
# File lib/shoryuken/polling/base.rb, line 35
def next_queue
  fail NotImplementedError
end