beamlime.applications.base.MessageRouter#

class beamlime.applications.base.MessageRouter[source]#

A message router that routes messages to handlers.

__init__()[source]#

Methods

__init__()

debug(msg, *args[, stacklevel])

error(msg, *args[, stacklevel])

info(msg, *args[, stacklevel])

register_handler(event_tp, handler)

route(message)

run()

Message router daemon.

send_message_async(message)

warning(msg, *args[, stacklevel])

Attributes

logger

async run()[source]#

Message router daemon.

Return type:

AsyncGenerator[MessageProtocol | None, None]