Class: Shoryuken::Polling::BaseStrategy

Inherits:
Object
  • Object
show all
Includes:
Util
Defined in:
lib/shoryuken/polling/base.rb

Direct Known Subclasses

StrictPriority, WeightedRoundRobin

Instance Method Summary collapse

Methods included from Util

#elapsed, #fire_event, #logger, #unparse_queues, #worker_name

Instance Method Details

#==(other) ⇒ Object 



49
50
51
52
53
54
55
56
57
58
59
60
 
# 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 ⇒ Object 



45
46
47
 
# File 'lib/shoryuken/polling/base.rb', line 45

def active_queues
  fail NotImplementedError
end

#delay ⇒ Object 



62
63
64
 
# File 'lib/shoryuken/polling/base.rb', line 62

def delay
  @delay || Shoryuken.options[:delay].to_f
end

#message_processed(_queue) ⇒ Object 



43
 
# File 'lib/shoryuken/polling/base.rb', line 43

def message_processed(_queue); end

#messages_found(_queue, _messages_found) ⇒ Object 



39
40
41
 
# File 'lib/shoryuken/polling/base.rb', line 39

def messages_found(_queue, _messages_found)
  fail NotImplementedError
end

#next_queue ⇒ Object 



35
36
37
 
# File 'lib/shoryuken/polling/base.rb', line 35

def next_queue
  fail NotImplementedError
end