Function initialize_queue

methods/MIRIX/mirix/queue/__init__.py:42–53

Initialize the queue with an optional server instance. The queue worker will invoke server.send_messages() when processing messages. This should be called during application startup (e.g., in FastAPI lifespan). Args: server: Server instance for processing messages

(server=None)

async def initialize_queue(server=None) -> None:
    """
    Initialize the queue with an optional server instance.

    The queue worker will invoke server.send_messages() when processing messages.
    This should be called during application startup (e.g., in FastAPI lifespan).

    Args:
        server: Server instance for processing messages
    """
    await _manager.initialize(server=server)
    logger.info("Queue initialized with server instance")


async def save(message: QueueMessage) -> None: