PatchedMessage

faststream.rabbit.testing.PatchedMessage #

Bases: IncomingMessage

Patched message class for testing purposes.

This class extends aio_pika's IncomingMessage class and is used to simulate RabbitMQ message handling during tests.

routing_key

ack(multiple=False)

Asynchronously acknowledge a message.

Source code in faststream/rabbit/testing.py

async def ack(self, multiple: bool = False) -> None:
    """Asynchronously acknowledge a message."""
    pass

nack(multiple=False, requeue=True)

Nack the message.

Source code in faststream/rabbit/testing.py

async def nack(self, multiple: bool = False, requeue: bool = True) -> None:
    """Nack the message."""
    pass

reject(requeue=False)

Rejects a task.

Source code in faststream/rabbit/testing.py

async def reject(self, requeue: bool = False) -> None:
    """Rejects a task."""
    pass