Index _ | A | B | C | D | E | F | G | H | I | L | M | N | O | P | R | S | T | U | W _ __call__() (mersal.outbox.OutboxStorage method) __init__() (mersal.activation.BuiltinHandlerActivator method) (mersal.activation.HandlerActivator method) (mersal.core.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.InternalHandlersActivator 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_sqlalchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorage method) (mersal_sqlalchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig method) (mersal_sqlalchemy.sqlalchemy_unit_of_work.SQLAlchemyUnitOfWork method) A address_transport_mapping (mersal.transport.TransportBridge parameter) AnyIOPeriodicTask (class in mersal.threading) AnyIOPeriodicTaskFactory (class in mersal.threading) app (mersal.activation.BuiltinHandlerActivator property) async_session_factory (mersal_sqlalchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig attribute) async_session_maker (mersal_sqlalchemy.sqlalchemy_unit_of_work.SQLAlchemyUnitOfWork parameter) autosubscribe (mersal.core.app.Mersal parameter) 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_sqlalchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig attribute) commit_action (mersal.unit_of_work.UnitOfWorkConfig attribute) commit_on_save (mersal_sqlalchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig attribute) commit_with_transaction (mersal.unit_of_work.UnitOfWorkConfig attribute) D debug (mersal.core.app.Mersal parameter) default_router_registration (mersal.core.app.Mersal parameter) default_sqlalchemy_close_action() (in module mersal_sqlalchemy.sqlalchemy_unit_of_work) default_sqlalchemy_commit_action() (in module mersal_sqlalchemy.sqlalchemy_unit_of_work) default_sqlalchemy_rollback_action() (in module mersal_sqlalchemy.sqlalchemy_unit_of_work) default_transport (mersal.transport.TransportBridge parameter) DefaultTransactionContext (class in mersal.transport) DefaultTransactionContextWithOwningApp (class in mersal.transport) destination_address (mersal.outbox.OutboxMessage attribute) (mersal.transport.OutgoingMessage attribute) E error_handler (mersal.core.app.Mersal parameter) error_tracker (mersal.core.app.Mersal parameter) events (mersal.lifespan.autosubscribe.AutosubscribeConfig attribute) F factory (mersal.activation.BuiltinHandlerActivator.register parameter) (mersal.activation.HandlerActivator.register parameter) fail_fast_checker (mersal.core.app.Mersal parameter) fail_fast_exceptions (mersal.core.app.Mersal parameter) forwarding_period (mersal.outbox.OutboxForwarder parameter) 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_sqlalchemy.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 handler_activator (mersal.core.app.Mersal parameter) HandlerActivator (class in mersal.activation) headers (mersal.outbox.OutboxMessage attribute) I idempotency (mersal.core.app.Mersal parameter) 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) InternalHandlersActivator (class in mersal.subscription) 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) L logger (mersal.outbox.OutboxForwarder parameter) logging_config (mersal.core.app.Mersal parameter) M max_parallelism (mersal.core.app.Mersal parameter) Mersal (class in mersal.core.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_sqlalchemy.sqlalchemy_outbox_storage module mersal_sqlalchemy.sqlalchemy_unit_of_work module message (mersal.activation.BuiltinHandlerActivator.get_handlers parameter) (mersal.activation.HandlerActivator.get_handlers parameter) message_body_serializer (mersal.core.app.Mersal parameter) message_headers_serializer (mersal.core.app.Mersal parameter) message_id_generator (mersal.core.app.Mersal parameter) message_type (mersal.activation.BuiltinHandlerActivator.register parameter) (mersal.activation.HandlerActivator.register parameter) 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_sqlalchemy.sqlalchemy_outbox_storage mersal_sqlalchemy.sqlalchemy_unit_of_work N name (mersal.core.app.Mersal parameter) O on_shutdown_hooks (mersal.core.app.Mersal parameter) on_startup_hooks (mersal.core.app.Mersal parameter) outbox (mersal.core.app.Mersal parameter) outbox_message_id (mersal.outbox.OutboxMessage attribute) outbox_storage (mersal.outbox.OutboxForwarder parameter) 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) outgoing_messages (mersal.outbox.in_memory.InMemoryOutboxStorage.save parameter) (mersal.outbox.OutboxStorage.save parameter) (mersal_sqlalchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorage.save parameter) OutgoingMessage (class in mersal.transport) P pdb_on_exception (mersal.core.app.Mersal parameter) periodic_task_factory (mersal.outbox.OutboxForwarder parameter) PeriodicAsyncTask (class in mersal.threading) PeriodicAsyncTaskFactory (class in mersal.threading) pipeline_invoker (mersal.core.app.Mersal parameter) plugins (mersal.core.app.Mersal parameter) publish() (mersal.core.app.Mersal method) R receive() (mersal.transport.in_memory.InMemoryTransport method) (mersal.transport.Transport method) (mersal.transport.TransportBridge method) 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) retry_strategy_settings (mersal.core.app.Mersal parameter) rollback_action (mersal.unit_of_work.UnitOfWorkConfig attribute) router (mersal.core.app.Mersal parameter) S saga (mersal.core.app.Mersal parameter) save() (mersal.outbox.in_memory.InMemoryOutboxStorage method) (mersal.outbox.OutboxStorage method) (mersal_sqlalchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorage method) send() (mersal.core.app.Mersal method) send-only send_local() (mersal.core.app.Mersal method) send_only (mersal.core.app.Mersal parameter) serializer (mersal.core.app.Mersal parameter) session_extractor (mersal_sqlalchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig attribute) should_stop_invocation (mersal.idempotency.IdempotencyConfig attribute) SQLAlchemyOutboxStorage (class in mersal_sqlalchemy.sqlalchemy_outbox_storage) SQLAlchemyOutboxStorageConfig (class in mersal_sqlalchemy.sqlalchemy_outbox_storage) SQLAlchemyUnitOfWork (class in mersal_sqlalchemy.sqlalchemy_unit_of_work) stop_grace_period (mersal.core.app.Mersal parameter) storage (mersal.outbox.OutboxConfig attribute) subscribe() (mersal.core.app.Mersal method) subscription_storage (mersal.core.app.Mersal parameter) SubscriptionStorage (class in mersal.subscription) T table_name (mersal_sqlalchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig attribute) topic (mersal.persistence.in_memory.InMemorySubscriptionStorage.get_subscriber_addresses parameter) (mersal.subscription.SubscriptionStorage.get_subscriber_addresses parameter) topic_name_convention (mersal.core.app.Mersal parameter) 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) transaction_context (mersal.activation.BuiltinHandlerActivator.get_handlers parameter) (mersal.activation.HandlerActivator.get_handlers parameter) (mersal.outbox.in_memory.InMemoryOutboxStorage.save parameter) (mersal.outbox.OutboxStorage.save parameter) (mersal_sqlalchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorage.save parameter) TransactionContext (class in mersal.transport) Transport (class in mersal.transport) transport (mersal.core.app.Mersal parameter) (mersal.outbox.OutboxForwarder parameter) transport_message (mersal.transport.OutgoingMessage attribute) transport_message() (mersal.outbox.OutboxMessage method) TransportBridge (class in mersal.transport) U unit_of_work (mersal.core.app.Mersal parameter) UnitOfWorkConfig (class in mersal.unit_of_work) unregister_subscriber() (mersal.persistence.in_memory.InMemorySubscriptionStorage method) (mersal.subscription.SubscriptionStorage method) unsubscribe() (mersal.core.app.Mersal method) uow_factory (mersal.unit_of_work.UnitOfWorkConfig attribute) W worker_factory (mersal.core.app.Mersal parameter)