minos.networks.brokers.publishers.services module

class minos.networks.brokers.publishers.services.BrokerProducerService(**kwargs)[source]

Bases: aiomisc.service.base.Service

Broker Producer Service class.

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

aiomisc.context.Context

dispatcher

Get the service dispatcher.

Returns

A Producer 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.