minos.networks.brokers.handlers.impl

Classes

BrokerHandler

Broker Handler class.

class BrokerHandler

Bases: SetupMixin

Broker Handler class.

__init__(dispatcher, subscriber, concurrency=5, *args, **kwargs)

Parameters

• dispatcher (BrokerDispatcher) –

• subscriber (BrokerSubscriber) –

• concurrency (int) –

async run()

Run the message handling process.

Returns

This method does not return anything.

Return type

NoReturn

property already_destroyed: bool

Already Destroy getter.

Returns

A boolean value.

property already_setup: bool

Already Setup getter.

Returns

A boolean value.

async destroy()

Destroy miscellaneous repository things.

Returns

This method does not return anything.

Return type

None

classmethod from_config(config=None, **kwargs)

Build a new instance from config.

Parameters

• config (Optional[Union[Config, Path]]) – Config instance. If None is provided, default config is chosen.

• kwargs – Additional named arguments.

Returns

A instance of the called class.

Return type

S

async setup()

Setup miscellaneous repository things.

Returns

This method does not return anything.

Return type

None