minos.networks.brokers.publishers.queued.queues.abc

Classes

Broker Publisher Queue class.

class BrokerPublisherQueue[source]

Bases: BrokerQueue, ABC

Broker Publisher Queue class.

__init__(*args, already_setup=False, **kwargs)

property already_destroyed: bool

Already Destroy getter.

property already_setup: bool

Already Setup getter.

async dequeue()

Dequeue method.

async destroy()

Destroy miscellaneous repository things.

async enqueue(message)

Enqueue method.

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

classmethod get_builder()

Get the builder class.

classmethod set_builder(builder)

Set a builder class.

Parameters: builder (Union[Builder[Ins], type[minos.common.builders.Builder[~Ins]]]) – The builder class to be set.
Returns: This method does not return anything.
Return type: None

async setup()

Setup miscellaneous repository things.