Skip to content

AckPolicy

faststream.AckPolicy #

Bases: str, Enum

ACK_FIRST class-attribute instance-attribute #

ACK_FIRST = 'ack_first'

Ack message on consume.

ACK class-attribute instance-attribute #

ACK = 'ack'

Ack message after all process.

REJECT_ON_ERROR class-attribute instance-attribute #

REJECT_ON_ERROR = 'reject_on_error'

Reject message on unhandled exceptions.

NACK_ON_ERROR class-attribute instance-attribute #

NACK_ON_ERROR = 'nack_on_error'

Nack message on unhandled exceptions.

MANUAL class-attribute instance-attribute #

MANUAL = 'manual'

Disable default FastStream Acknowledgement logic. User should confirm all actions manually.