compass.services.queues.get_service_queue

get_service_queue(service_name)

Retrieve the queue for a service

Parameters:

service_name (str) – Name of service to retrieve queue for.

Returns:

asyncio.Queue or None – Queue instance for this service, or None if the queue was not initialized.