Class: Shoryuken::WorkerRegistry
- Inherits:
-
Object
- Object
- Shoryuken::WorkerRegistry
- Defined in:
- lib/shoryuken/worker_registry.rb
Direct Known Subclasses
Instance Method Summary collapse
- #batch_receive_messages?(_queue) ⇒ Boolean
- #clear ⇒ Object
- #fetch_worker(_queue, _message) ⇒ Object
- #queues ⇒ Object
- #register_worker(_queue, _clazz) ⇒ Object
- #workers(_queue) ⇒ Object
Instance Method Details
#batch_receive_messages?(_queue) ⇒ Boolean
3 4 5 6 |
# File 'lib/shoryuken/worker_registry.rb', line 3 def (_queue) # true if the workers for queue support batch processing of messages fail NotImplementedError end |
#clear ⇒ Object
8 9 10 11 |
# File 'lib/shoryuken/worker_registry.rb', line 8 def clear # must remove all worker registrations fail NotImplementedError end |
#fetch_worker(_queue, _message) ⇒ Object
13 14 15 16 17 |
# File 'lib/shoryuken/worker_registry.rb', line 13 def fetch_worker(_queue, ) # must return an instance of the worker that handles # message received on queue fail NotImplementedError end |
#queues ⇒ Object
19 20 21 22 |
# File 'lib/shoryuken/worker_registry.rb', line 19 def queues # must return a list of all queues with registered workers fail NotImplementedError end |
#register_worker(_queue, _clazz) ⇒ Object
24 25 26 27 |
# File 'lib/shoryuken/worker_registry.rb', line 24 def register_worker(_queue, _clazz) # must register the worker as a consumer of messages from queue fail NotImplementedError end |
#workers(_queue) ⇒ Object
29 30 31 32 |
# File 'lib/shoryuken/worker_registry.rb', line 29 def workers(_queue) # must return the list of workers registered for queue, or [] fail NotImplementedError end |