in_memory¶
- class mersal.persistence.in_memory.in_memory_message_tracker.InMemoryMessageTracker[source]¶
Bases:
MessageTrackerTracks handled messages in memory.
- async is_message_tracked(message_id: UUID, transaction_context: TransactionContext) bool[source]¶
Check if message identified by message_id is handled.
- async track_message(message_id: UUID, transaction_context: TransactionContext) None[source]¶
Set message identified by message_id as handled.