Contents Menu Expand Light mode Dark mode Auto light/dark, in light mode Auto light/dark, in dark mode Skip to content
Mersal 0.9.2.dev7 documentation
Mersal 0.9.2.dev7 documentation

Documentation

  • Quick Start
  • Example Theme
  • Usage
    • Mersal App
    • Message Handlers
    • Sending Messages
    • Receiving Messages
    • Pub/Sub
    • Routing
    • Error Handling
    • Message Context
    • Message Headers
    • Idempotency
    • Outbox
    • Unit of Work
    • Transport Bridge
    • Transactions
    • Message Processing Pipeline
    • Workers
    • Plugins
    • contrib
      • polling
  • Tutorials
  • Glossary
  • API reference
    • app
    • activation
    • idempotency
      • in_memory
    • outbox
      • in_memory
    • threading
    • transport
      • in_memory
    • unit_of_work
    • subscription
    • persistence
    • autosubscribe
    • topic
    • contrib
      • sqlalchemy
        • outbox
        • unit_of_work
Back to top
View this page

in_memory¶

class mersal.persistence.in_memory.in_memory_message_tracker.InMemoryMessageTracker[source]¶

Bases: MessageTracker

Tracks handled messages in memory.

__init__() → None[source]¶
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.

Next
outbox
Previous
idempotency
Copyright © 2023, Abdulhaq Emhemmed
Made with Sphinx and @pradyunsg's Furo
On this page
  • in_memory
    • InMemoryMessageTracker
      • InMemoryMessageTracker.__init__()
      • InMemoryMessageTracker.is_message_tracked()
      • InMemoryMessageTracker.track_message()