Base

flowtask.hooks.types.brokers.base

BaseMQTrigger

BaseMQTrigger(*args, actions=None, **kwargs)

Bases: BaseTrigger

connect abstractmethod async

connect()

Establish the connection.

disconnect abstractmethod async

disconnect()

Disconnect the connection.

start_consuming abstractmethod async

start_consuming()

Start consuming messages.