Skip to content

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 instance-attribute #

routing_key: str

ack async #

ack(multiple: bool = False) -> None

Asynchronously acknowledge a message.

Source code in faststream/rabbit/testing.py 
152
153
async def ack(self, multiple: bool = False) -> None:
    """Asynchronously acknowledge a message."""

nack async #

nack(multiple: bool = False, requeue: bool = True) -> None

Nack the message.

Source code in faststream/rabbit/testing.py 
155
156
async def nack(self, multiple: bool = False, requeue: bool = True) -> None:
    """Nack the message."""

reject async #

reject(requeue: bool = False) -> None

Rejects a task.

Source code in faststream/rabbit/testing.py 
158
159
async def reject(self, requeue: bool = False) -> None:
    """Rejects a task."""