Rabbitmq

flowtask.hooks.types.brokers.rabbitmq

RabbitMQTrigger

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

Bases: BaseMQTrigger