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