idempotency

class mersal.idempotency.IdempotencyConfig[source]

Bases: object

Configuration for idempotency.

__init__(tracker: MessageTracker, should_stop_invocation: bool) → None
should_stop_invocation: bool

Whether to run message handlers for repeated messages or not.

tracker: MessageTracker

Message tracking persistence mechanism.

class mersal.idempotency.IdempotencyPlugin[source]

Bases: Plugin

__init__(config: IdempotencyConfig)[source]
class mersal.idempotency.MessageTracker[source]

Bases: Protocol

Idempotency tracker.

__init__(*args, **kwargs)
async is_message_tracked(message_id: Any, transaction_context: TransactionContext) → bool[source]

Check if message identified by message_id is handled.

async track_message(message_id: Any, transaction_context: TransactionContext) → None[source]

Set message identified by message_id as handled.