Sha256: f555d0d2116349c2c1a4115c7bebf8d23ea90b95de94cad4cd326cf246c77d9e
Contents?: true
Size: 877 Bytes
Versions: 27
Compression:
Stored size: 877 Bytes
Contents
module Shoryuken
class WorkerRegistry
def batch_receive_messages?(_queue)
# true if the workers for queue support batch processing of messages
fail NotImplementedError
end
def clear
# must remove all worker registrations
fail NotImplementedError
end
def fetch_worker(_queue, _message)
# must return an instance of the worker that handles
# message received on queue
fail NotImplementedError
end
def queues
# must return a list of all queues with registered workers
fail NotImplementedError
end
def register_worker(_queue, _clazz)
# must register the worker as a consumer of messages from queue
fail NotImplementedError
end
def workers(_queue)
# must return the list of workers registered for queue, or []
fail NotImplementedError
end
end
end
Version data entries
27 entries across 27 versions & 1 rubygems