in_memory¶

class mersal.transport.in_memory.InMemoryTransport[source]¶

Bases: BaseTransport

__init__(config: InMemoryTransportConfig) → None[source]¶

async receive(transaction_context: TransactionContext) → TransportMessage | None[source]¶

Return the next incoming message, or None if none is available.

Implementations may wait internally for a message but must return (a message or None) within a bounded time rather than blocking indefinitely: the worker treats each return as a liveness signal, and idle waiting is the job of the worker’s backoff strategy, not the transport.

class mersal.transport.in_memory.InMemoryTransportConfig[source]¶

Bases: object

InMemoryTransportConfig(network: ‘InMemoryNetwork’, input_queue_address: ‘str’)

__init__(network: InMemoryNetwork, input_queue_address: str) → None¶