minos.networks.brokers.handlers.services module

class minos.networks.brokers.handlers.services.BrokerConsumerService(consumer=<dependency_injector.wiring.Provide object>, **kwargs)[source]

Bases: aiomisc.service.base.Service

Broker Consumer Service class.

__init__(consumer=<dependency_injector.wiring.Provide object>, **kwargs)[source]
property context: aiomisc.context.Context
Return type

aiomisc.context.Context

set_loop(loop)
Return type

None

async start()[source]

Start the service execution.

Return type

None

Returns

This method does not return anything.

property start_event: asyncio.locks.Event
Return type

asyncio.locks.Event

async stop(exception=None)[source]

Stop the service execution.

Parameters

exception (typing.Optional[Exception]) – Optional exception that stopped the execution.

Return type

typing.Any

Returns

This method does not return anything.

class minos.networks.brokers.handlers.services.BrokerHandlerService(**kwargs)[source]

Bases: aiomisc.service.base.Service

Broker Handler Service class.

__init__(**kwargs)[source]
property context: aiomisc.context.Context
Return type

aiomisc.context.Context

handler

Get the service handler.

Returns

A Handler instance.

set_loop(loop)
Return type

None

async start()[source]

Start the service execution.

Return type

None

Returns

This method does not return anything.

property start_event: asyncio.locks.Event
Return type

asyncio.locks.Event

async stop(err=None)[source]

Stop the service execution.

Parameters

err (typing.Optional[Exception]) – Optional exception that stopped the execution.

Return type

None

Returns

This method does not return anything.