Router

Each queue is linked to a router which describe how the applicative server processes the messages of the queue.

from kova.protocol.ping_pb2 import EchoRequest, EchoResponse
from kova.router import Router

from kova.message import Reply
from loguru import logger

router = Router()


@router.subscribe("*.echo")
async def echo(msg: EchoRequest, reply: Reply):
    logger.debug(f"Received message: '{msg.message}'")
    if reply:
        res = EchoResponse()
        res.message = f"echo {msg.message}"
        await reply(res.SerializeToString())
        logger.debug("Response sent")
    else:
        logger.warning("Unable to reply")

This router listens on the *.echo queue. It will receive an EchoRequest and if the message needs a Reply will answer with an EchoResponse. The echo function will be called everytime a message is processed on the *.echo queue.

The router function (in this case echo) can take several parameters :

• a Message : of the message type expected on this queue (here EchoRequest)
• an optional Reply : if the router is supposed to answer, in the event of Request/Reply messaging
• an optional CurrentUser : the user who sent the message
• an optional Cache object