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])

rtype:

None

error(msg, *args[, stacklevel])

rtype:

None

info(msg, *args[, stacklevel])

rtype:

None

register_handler(event_tp, handler)

route(message)

rtype:

None

run()

Message router daemon.

send_message_async(message)

rtype:

None

warning(msg, *args[, stacklevel])

rtype:

None

Attributes

logger

async run()[source]#

Message router daemon.

Return type:

AsyncGenerator[MessageProtocol | None, None]