saturn_engine.worker.topics.rabbitmq#

Classes

Exchange(name, type, durable, auto_delete, ...)

RabbitMQSerializer(value[, names, module, ...])

RabbitMQTopic(options, services, **kwargs)

A queue that consume message from RabbitMQ