From 00837e9ac74b543a89689248bbd8192282ad4dd6 Mon Sep 17 00:00:00 2001 From: martin sereinig Date: Sat, 15 Nov 2025 11:03:24 +0100 Subject: [PATCH] reject can no longer be passed to `AckableMessage` --- docs/extending-taskiq/broker.md | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/docs/extending-taskiq/broker.md b/docs/extending-taskiq/broker.md index f30002dd..537227f9 100644 --- a/docs/extending-taskiq/broker.md +++ b/docs/extending-taskiq/broker.md @@ -26,8 +26,7 @@ As a broker developer, please send only raw bytes from the `message` field of a ## Acknowledgement The `listen` method should yield raw bytes of a message. -But if your broker supports acking or rejecting messages, the broker should return `taskiq.AckableMessage` -with required fields. +But if your broker supports acking messages, the broker should return `taskiq.AckableMessage` with the required field. For example: @@ -40,9 +39,7 @@ async def listen(self) -> AsyncGenerator[AckableMessage, None]: # Ack is a function that takes no parameters. # So you either set here method of a message, # or you can make a closure. - ack=message.ack - # Can be set to None if broker doesn't support it. - reject=message.reject + ack=message.ack, ) ```