asyncworker.rabbitmq package#

Submodules#

asyncworker.rabbitmq.entrypoints module#

class asyncworker.rabbitmq.entrypoints.AMQPRouteEntryPointImpl(app: asyncworker.app.App)[código fonte]#

Base: asyncworker.entrypoints.EntrypointInterface

consume(routes: typing.List[str], vhost: str = '/', connection: typing.Optional[asyncworker.connections.AMQPConnection] = None, options: typing.Optional[asyncworker.routes.AMQPRouteOptions] = AMQPRouteOptions(bulk_size=1, bulk_flush_interval=60, on_success=<Actions.ACK: 'ack'>, on_exception=<Actions.REQUEUE: 'requeue'>, connection_fail_callback=None, connection=None))[código fonte]#

asyncworker.rabbitmq.message module#

class asyncworker.rabbitmq.message.RabbitMQMessage(delivery_tag: int, amqp_message: asyncworker.easyqueue.message.AMQPMessage, on_success: asyncworker.options.Actions = Actions.ACK, on_exception: asyncworker.options.Actions = Actions.REQUEUE)[código fonte]#

Base: object

accept()[código fonte]#

Marca essa mensagem para ser confirmada (ACK) ao fim da execução do handler.

property body#
async process_exception()[código fonte]#
async process_success()[código fonte]#
reject(requeue=True)[código fonte]#

Marca essa mensagem para ser rejeitada. O parametro requeue indica se a mensagem será recolocada na fila original (requeue=True) ou será descartada (requeue=False).

property serialized_data#

Module contents#