Class: Shoryuken::Polling::BaseStrategy
- Inherits:
-
Object
- Object
- Shoryuken::Polling::BaseStrategy
show all
- Includes:
- Util
- Defined in:
- lib/shoryuken/polling/base.rb
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
|