Index Symbols | _ | A | B | C | D | E | F | G | H | I | L | M | N | O | P | R | S | T | U | W Symbols *args (mersal.exceptions.MersalExceptionError parameter) (mersal.exceptions.MissingDependencyExceptionError parameter) _ __call__() (mersal.outbox.OutboxStorage method) (mersal.timeouts.TimeoutManager method) __init__() (mersal.activation.BuiltinHandlerActivator method) (mersal.activation.HandlerActivator method) (mersal.core.app.Mersal method) (mersal.exceptions.MersalExceptionError method) (mersal.exceptions.MissingDependencyExceptionError 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.persistence.in_memory.InMemoryTimeoutManager method) (mersal.sqlalchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorage method) (mersal.sqlalchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig method) (mersal.sqlalchemy.sqlalchemy_unit_of_work.SQLAlchemyUnitOfWork 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.timeouts.DueMessage method) (mersal.timeouts.DueMessagesSender method) (mersal.timeouts.HandleDeferredMessagesStep method) (mersal.timeouts.TimeoutManager method) (mersal.timeouts.TimeoutsConfig method) (mersal.timeouts.TimeoutsPlugin 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) 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) ConcurrencyExceptionError 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) defer() (mersal.core.app.Mersal method) (mersal.persistence.in_memory.InMemoryTimeoutManager method) (mersal.timeouts.DisabledTimeoutManager method) (mersal.timeouts.TimeoutManager method) defer_local() (mersal.core.app.Mersal method) DeferralNotSupportedError destination_address (mersal.outbox.OutboxMessage attribute) (mersal.transport.OutgoingMessage attribute) detail (mersal.exceptions.MersalExceptionError parameter) (mersal.exceptions.MissingDependencyExceptionError parameter) DisabledTimeoutManager (class in mersal.timeouts) DueMessage (class in mersal.timeouts) DueMessagesSender (class in mersal.timeouts) E error_handler (mersal.core.app.Mersal parameter) error_tracker (mersal.core.app.Mersal parameter) events (mersal.lifespan.autosubscribe.AutosubscribeConfig attribute) external_timeout_manager_address (mersal.timeouts.TimeoutsConfig 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_due_messages() (mersal.persistence.in_memory.InMemoryTimeoutManager method) (mersal.timeouts.DisabledTimeoutManager method) (mersal.timeouts.TimeoutManager method) 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 HandleDeferredMessagesStep (class in mersal.timeouts) 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) InMemoryTimeoutManager (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) (mersal.timeouts.DueMessagesSender parameter) logging_config (mersal.core.app.Mersal parameter) M mark_as_completed (mersal.timeouts.DueMessage attribute) max_parallelism (mersal.core.app.Mersal parameter) Mersal (class in mersal.core.app) mersal.activation module mersal.exceptions 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.sqlalchemy.sqlalchemy_outbox_storage module mersal.sqlalchemy.sqlalchemy_unit_of_work module mersal.subscription module mersal.threading module mersal.timeouts module mersal.topic module mersal.transport module mersal.transport.in_memory module mersal.unit_of_work module MersalExceptionError message (mersal.activation.BuiltinHandlerActivator.get_handlers parameter) (mersal.activation.HandlerActivator.get_handlers parameter) (mersal.timeouts.DueMessage attribute) 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) MissingDependencyExceptionError module mersal.activation mersal.exceptions mersal.idempotency mersal.lifespan.autosubscribe mersal.outbox mersal.outbox.in_memory mersal.persistence.in_memory mersal.persistence.in_memory.in_memory_message_tracker mersal.sqlalchemy.sqlalchemy_outbox_storage mersal.sqlalchemy.sqlalchemy_unit_of_work mersal.subscription mersal.threading mersal.timeouts mersal.topic mersal.transport mersal.transport.in_memory mersal.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) (mersal.timeouts.DueMessagesSender parameter) PeriodicAsyncTask (class in mersal.threading) PeriodicAsyncTaskFactory (class in mersal.threading) pipeline_invoker (mersal.core.app.Mersal parameter) plugins (mersal.core.app.Mersal parameter) poll_interval (mersal.timeouts.DueMessagesSender parameter) (mersal.timeouts.TimeoutsConfig attribute) publish() (mersal.core.app.Mersal method) publish_base_types (mersal.core.app.Mersal parameter) 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) (mersal.timeouts.TimeoutsConfig attribute) subscribe() (mersal.core.app.Mersal method) subscription_storage (mersal.core.app.Mersal parameter) SubscriptionStorage (class in mersal.subscription) supports_deferral (mersal.transport.Transport property) (mersal.transport.TransportBridge property) T table_name (mersal.sqlalchemy.sqlalchemy_outbox_storage.SQLAlchemyOutboxStorageConfig attribute) timeout_manager (mersal.timeouts.DueMessagesSender parameter) TimeoutManager (class in mersal.timeouts) timeouts (mersal.core.app.Mersal parameter) TimeoutsConfig (class in mersal.timeouts) TimeoutsPlugin (class in mersal.timeouts) 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) (mersal.timeouts.DueMessagesSender 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)