Add transaction timeout duration configuration for TransactionOptions in Outbox feature

src/SqlPersistence/Outbox/SqlOutboxFeature.cs

@@ -28,6 +28,7 @@ protected override void Setup(FeatureConfigurationContext context)
             adoTransactionIsolationLevel = System.Data.IsolationLevel.ReadCommitted;
         }
         var transactionScopeIsolationLevel = context.Settings.GetOrDefault<System.Transactions.IsolationLevel>(TransactionScopeIsolationLevel);
+        var transactionScopeTimeout = context.Settings.GetOrDefault<TimeSpan>(TransactionScopeTimeout);
 
         var outboxCommands = OutboxCommandBuilder.Build(sqlDialect, tablePrefix);
 
@@ -44,7 +45,7 @@ protected override void Setup(FeatureConfigurationContext context)
         ISqlOutboxTransaction transactionFactory()
         {
             return transactionScopeMode
-                ? (ISqlOutboxTransaction)new TransactionScopeSqlOutboxTransaction(concurrencyControlStrategy, connectionManager, transactionScopeIsolationLevel)
+                ? (ISqlOutboxTransaction)new TransactionScopeSqlOutboxTransaction(concurrencyControlStrategy, connectionManager, transactionScopeIsolationLevel, transactionScopeTimeout)
                 : new AdoNetSqlOutboxTransaction(concurrencyControlStrategy, connectionManager, adoTransactionIsolationLevel);
         }
 
@@ -87,4 +88,5 @@ ISqlOutboxTransaction transactionFactory()
     internal const string UseTransactionScope = "Persistence.Sql.Outbox.TransactionScopeMode";
     internal const string AdoTransactionIsolationLevel = "Persistence.Sql.Outbox.AdoTransactionIsolationLevel";
     internal const string TransactionScopeIsolationLevel = "Persistence.Sql.Outbox.TransactionScopeIsolationLevel";
+    internal const string TransactionScopeTimeout = "Persistence.Sql.Outbox.TransactionScopeTimeout";
 }

src/SqlPersistence/Outbox/SqlPersistenceOutboxSettingsExtensions.cs

@@ -107,5 +107,19 @@ public static void UseTransactionScope(this OutboxSettings outboxSettings, Isola
             outboxSettings.GetSettings().Set(SqlOutboxFeature.UseTransactionScope, true);
             outboxSettings.GetSettings().Set(SqlOutboxFeature.TransactionScopeIsolationLevel, isolationLevel);
         }
+
+        /// <summary>
+        /// Configures the outbox to use TransactionScope instead of SqlTransaction. This allows wrapping the
+        /// the outbox transaction (and synchronized storage session it manages) and other database transactions in a single scope - provided that
+        /// Distributed Transaction Coordinator (DTC) infrastructure is configured.
+        /// </summary>
+        /// <param name="outboxSettings">Outbox settings.</param>
+        /// <param name="isolationLevel">Isolation level to use. Only levels Read Committed, Repeatable Read and Serializable are supported.</param>
+        /// <param name="timeout">timeout period for the transaction.</param>
+        public static void UseTransactionScope(this OutboxSettings outboxSettings, IsolationLevel isolationLevel, TimeSpan timeout)
+        {
+            outboxSettings.UseTransactionScope(isolationLevel);
+            outboxSettings.GetSettings().Set(SqlOutboxFeature.TransactionScopeTimeout, timeout);
+        }
     }
 }

src/SqlPersistence/Outbox/TransactionScopeSqlOutboxTransaction.cs

@@ -1,4 +1,5 @@
-using System.Data.Common;
+using System;
+using System.Data.Common;
 using System.Threading;
 using System.Threading.Tasks;
 using System.Transactions;
@@ -16,13 +17,15 @@ class TransactionScopeSqlOutboxTransaction : ISqlOutboxTransaction
     TransactionScope transactionScope;
     Transaction ambientTransaction;
     bool commit;
+    TimeSpan transactionTimeout;
 
     public TransactionScopeSqlOutboxTransaction(ConcurrencyControlStrategy concurrencyControlStrategy,
-        IConnectionManager connectionManager, IsolationLevel isolationLevel)
+        IConnectionManager connectionManager, IsolationLevel isolationLevel, TimeSpan transactionTimeout = default)
     {
         this.connectionManager = connectionManager;
         this.isolationLevel = isolationLevel;
         this.concurrencyControlStrategy = concurrencyControlStrategy;
+        this.transactionTimeout = transactionTimeout;
     }
 
     public DbTransaction Transaction => null;
@@ -33,7 +36,8 @@ public void Prepare(ContextBag context)
     {
         var options = new TransactionOptions
         {
-            IsolationLevel = isolationLevel
+            IsolationLevel = isolationLevel,
+            Timeout = transactionTimeout
         };
 
         transactionScope = new TransactionScope(TransactionScopeOption.RequiresNew, options, TransactionScopeAsyncFlowOption.Enabled);