Index

_

__call__() (mersal.outbox.OutboxStorage method) __init__() (mersal.activation.BuiltinHandlerActivator method) (mersal.activation.HandlerActivator method) (mersal.app.Mersal method) (mersal.idempotency.IdempotencyConfig method) (mersal.idempotency.IdempotencyPlugin method) (mersal.idempotency.MessageTracker method) (mersal.lifespan.autosubscribe.AutosubscribeConfig method) (mersal.outbox.in_memory.InMemoryOutboxStorage method) (mersal.outbox.OutboxConfig method) (mersal.outbox.OutboxForwarder method) (mersal.outbox.OutboxMessage method) (mersal.outbox.OutboxMessageBatch method) (mersal.outbox.OutboxStorage method) (mersal.persistence.in_memory.in_memory_message_tracker.InMemoryMessageTracker method) (mersal.persistence.in_memory.InMemoryMessageTracker method) (mersal.persistence.in_memory.InMemorySagaStorage method) (mersal.persistence.in_memory.InMemorySubscriptionStorage method) (mersal.persistence.in_memory.InMemorySubscriptionStore method) (mersal.subscription.SubscriptionStorage method) (mersal.threading.AnyIOPeriodicTask method) (mersal.threading.AnyIOPeriodicTaskFactory method) (mersal.threading.PeriodicAsyncTask method) (mersal.threading.PeriodicAsyncTaskFactory method) (mersal.topic.TopicNameConvention method) (mersal.transport.DefaultTransactionContext method) (mersal.transport.DefaultTransactionContextWithOwningApp method) (mersal.transport.in_memory.InMemoryTransport method) (mersal.transport.in_memory.InMemoryTransportConfig method) (mersal.transport.OutgoingMessage method) (mersal.transport.TransactionContext method) (mersal.transport.Transport method) (mersal.transport.TransportBridge method) (mersal.unit_of_work.UnitOfWorkConfig method) (mersal_alchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorage method) (mersal_alchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig method) (mersal_alchemy.sqlalchemy_unit_of_work.SQLAlchemyUnitOfWork method)

A

AnyIOPeriodicTask (class in mersal.threading) AnyIOPeriodicTaskFactory (class in mersal.threading)

app (mersal.activation.BuiltinHandlerActivator property) async_session_factory (mersal_alchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig attribute) AutosubscribeConfig (class in mersal.lifespan.autosubscribe)

B

body (mersal.outbox.OutboxMessage attribute)

BuiltinHandlerActivator (class in mersal.activation)

C

close_action (mersal.unit_of_work.UnitOfWorkConfig attribute) close_session_on_save (mersal_alchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig attribute)

commit_action (mersal.unit_of_work.UnitOfWorkConfig attribute) commit_on_save (mersal_alchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig attribute) commit_with_transaction (mersal.unit_of_work.UnitOfWorkConfig attribute)

D

default_sqlalchemy_close_action() (in module mersal_alchemy.sqlalchemy_unit_of_work) default_sqlalchemy_commit_action() (in module mersal_alchemy.sqlalchemy_unit_of_work) default_sqlalchemy_rollback_action() (in module mersal_alchemy.sqlalchemy_unit_of_work)

DefaultTransactionContext (class in mersal.transport) DefaultTransactionContextWithOwningApp (class in mersal.transport) destination_address (mersal.outbox.OutboxMessage attribute) (mersal.transport.OutgoingMessage attribute)

E

events (mersal.lifespan.autosubscribe.AutosubscribeConfig attribute)

G

get_handlers() (mersal.activation.BuiltinHandlerActivator method) (mersal.activation.HandlerActivator method) get_next_message_batch() (mersal.outbox.in_memory.InMemoryOutboxStorage method) (mersal.outbox.OutboxStorage method) (mersal_alchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorage method)

get_subscriber_addresses() (mersal.persistence.in_memory.InMemorySubscriptionStorage method) (mersal.subscription.SubscriptionStorage method) get_topic_name() (mersal.topic.TopicNameConvention method)

H

HandlerActivator (class in mersal.activation)

headers (mersal.outbox.OutboxMessage attribute)

I

IdempotencyConfig (class in mersal.idempotency) IdempotencyPlugin (class in mersal.idempotency) idempotent InMemoryMessageTracker (class in mersal.persistence.in_memory) (class in mersal.persistence.in_memory.in_memory_message_tracker) InMemoryOutboxStorage (class in mersal.outbox.in_memory) InMemorySagaStorage (class in mersal.persistence.in_memory) InMemorySubscriptionStorage (class in mersal.persistence.in_memory)

InMemorySubscriptionStore (class in mersal.persistence.in_memory) InMemoryTransport (class in mersal.transport.in_memory) InMemoryTransportConfig (class in mersal.transport.in_memory) is_centralized (mersal.persistence.in_memory.InMemorySubscriptionStorage property) (mersal.subscription.SubscriptionStorage property) is_message_tracked() (mersal.idempotency.MessageTracker method) (mersal.persistence.in_memory.in_memory_message_tracker.InMemoryMessageTracker method) (mersal.persistence.in_memory.InMemoryMessageTracker method)

M

Mersal (class in mersal.app) mersal.activation module mersal.idempotency module mersal.lifespan.autosubscribe module mersal.outbox module mersal.outbox.in_memory module mersal.persistence.in_memory module mersal.persistence.in_memory.in_memory_message_tracker module mersal.subscription module mersal.threading module mersal.topic module mersal.transport module mersal.transport.in_memory module

mersal.unit_of_work module mersal_alchemy.sqlalchemy_outbox_storage module mersal_alchemy.sqlalchemy_unit_of_work module MessageTracker (class in mersal.idempotency) module mersal.activation mersal.idempotency mersal.lifespan.autosubscribe mersal.outbox mersal.outbox.in_memory mersal.persistence.in_memory mersal.persistence.in_memory.in_memory_message_tracker mersal.subscription mersal.threading mersal.topic mersal.transport mersal.transport.in_memory mersal.unit_of_work mersal_alchemy.sqlalchemy_outbox_storage mersal_alchemy.sqlalchemy_unit_of_work

O

outbox outbox_message_id (mersal.outbox.OutboxMessage attribute) OutboxConfig (class in mersal.outbox) OutboxForwarder (class in mersal.outbox)

OutboxMessage (class in mersal.outbox) OutboxMessageBatch (class in mersal.outbox) OutboxStorage (class in mersal.outbox) OutgoingMessage (class in mersal.transport)

P

PeriodicAsyncTask (class in mersal.threading)

PeriodicAsyncTaskFactory (class in mersal.threading) publish() (mersal.app.Mersal method)

R

register() (mersal.activation.BuiltinHandlerActivator method) (mersal.activation.HandlerActivator method) register_subscriber() (mersal.persistence.in_memory.InMemorySubscriptionStorage method) (mersal.subscription.SubscriptionStorage method)

registered_message_types (mersal.activation.BuiltinHandlerActivator property) (mersal.activation.HandlerActivator property) rollback_action (mersal.unit_of_work.UnitOfWorkConfig attribute)

S

save() (mersal.outbox.in_memory.InMemoryOutboxStorage method) (mersal.outbox.OutboxStorage method) (mersal_alchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorage method) send() (mersal.app.Mersal method) send_local() (mersal.app.Mersal method) session_extractor (mersal_alchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig attribute)

should_stop_invocation (mersal.idempotency.IdempotencyConfig attribute) SQLAlchemyOutboxStorage (class in mersal_alchemy.sqlalchemy_outbox_storage) SQLAlchemyOutboxStorageConfig (class in mersal_alchemy.sqlalchemy_outbox_storage) SQLAlchemyUnitOfWork (class in mersal_alchemy.sqlalchemy_unit_of_work) storage (mersal.outbox.OutboxConfig attribute) subscribe() (mersal.app.Mersal method) SubscriptionStorage (class in mersal.subscription)

T

table_name (mersal_alchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig attribute) TopicNameConvention (class in mersal.topic) track_message() (mersal.idempotency.MessageTracker method) (mersal.persistence.in_memory.in_memory_message_tracker.InMemoryMessageTracker method) (mersal.persistence.in_memory.InMemoryMessageTracker method)

tracker (mersal.idempotency.IdempotencyConfig attribute) TransactionContext (class in mersal.transport) Transport (class in mersal.transport) transport_message (mersal.transport.OutgoingMessage attribute) transport_message() (mersal.outbox.OutboxMessage method) TransportBridge (class in mersal.transport)

U

UnitOfWorkConfig (class in mersal.unit_of_work) unregister_subscriber() (mersal.persistence.in_memory.InMemorySubscriptionStorage method) (mersal.subscription.SubscriptionStorage method)

uow_factory (mersal.unit_of_work.UnitOfWorkConfig attribute)