Brokers¶

flowtask.hooks.types.brokers ¶

Message Brokers.

Message Brokers are services that allow applications to send and receive messages.

Supported Message Brokers on Flowtask are: - MQTT - SQS - Redis - RabbitMQ

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

connect()

Establish the connection.

disconnect()

Disconnect the connection.

start_consuming()

Start consuming messages.

RabbitMQTrigger(*args, queue_name, routing_key='', exchange_name='', exchange_type='topic', credentials=None, actions=None, **kwargs)

RedisTrigger(*args, stream_name, group_name='default_group', consumer_name='default_consumer', credentials=None, actions=None, **kwargs)

Redis Trigger.

Trigger that listens to a Redis Stream and calls actions based on the received messages.