Align names and namespaces with the v7 branch (#88)

Particular · Sep 9, 2022 · b4fe130 · b4fe130
1 parent 5922f2d
commit b4fe130
Show file tree

Hide file tree

Showing 8 changed files with 26 additions and 28 deletions.
diff --git a/...n.CustomTestingPersistence/Transaction.cs → ...rsistence/AcceptanceTestingTransaction.cs b/...n.CustomTestingPersistence/Transaction.cs → ...rsistence/AcceptanceTestingTransaction.cs
@@ -3,7 +3,7 @@ namespace NServiceBus.AcceptanceTesting
     using System;
     using System.Collections.Generic;
 
-    class Transaction
+    sealed class AcceptanceTestingTransaction
     {
         public void Enlist(Action action) => actions.Add(action);
 

diff --git a/...CustomTestingPersistence/OutboxStorage.cs → ...istence/CustomTestingOutboxPersistence.cs b/...CustomTestingPersistence/OutboxStorage.cs → ...istence/CustomTestingOutboxPersistence.cs
@@ -4,17 +4,17 @@ namespace NServiceBus.AcceptanceTesting
     using Microsoft.Extensions.DependencyInjection;
     using Outbox;
 
-    class OutboxStorage : Feature
+    sealed class CustomTestingOutboxPersistence : Feature
     {
-        public OutboxStorage()
+        public CustomTestingOutboxPersistence()
         {
             DependsOn<Outbox>();
-            Defaults(s => s.EnableFeatureByDefault<SynchronizedStorage>());
+            Defaults(s => s.EnableFeatureByDefault<CustomTestingSynchronizedStorageFeature>());
         }
 
         protected override void Setup(FeatureConfigurationContext context)
         {
-            var outboxStorage = new OutboxPersister();
+            var outboxStorage = new CustomTestingOutboxStorage();
 
             context.Services.AddSingleton(typeof(IOutboxStorage), outboxStorage);
         }

diff --git a/...stomTestingPersistence/OutboxPersister.cs → ...Persistence/CustomTestingOutboxStorage.cs b/...stomTestingPersistence/OutboxPersister.cs → ...Persistence/CustomTestingOutboxStorage.cs
@@ -7,7 +7,7 @@ namespace NServiceBus.AcceptanceTesting
     using Extensibility;
     using Outbox;
 
-    class OutboxPersister : IOutboxStorage
+    sealed class CustomTestingOutboxStorage : IOutboxStorage
     {
         public Task<OutboxMessage> Get(string messageId, ContextBag context, CancellationToken cancellationToken = default)
         {
@@ -26,12 +26,12 @@ public Task<OutboxMessage> Get(string messageId, ContextBag context, Cancellatio
 
         public Task<IOutboxTransaction> BeginTransaction(ContextBag context, CancellationToken cancellationToken = default)
         {
-            return Task.FromResult<IOutboxTransaction>(new OutboxTransaction(context));
+            return Task.FromResult<IOutboxTransaction>(new CustomTestingOutboxTransaction(context));
         }
 
         public Task Store(OutboxMessage message, IOutboxTransaction transaction, ContextBag context, CancellationToken cancellationToken = default)
         {
-            var tx = (OutboxTransaction)transaction;
+            var tx = (CustomTestingOutboxTransaction)transaction;
             tx.Enlist(() =>
             {
                 if (!storage.TryAdd(message.MessageId, new StoredMessage(message.MessageId, message.TransportOperations)))

diff --git a/...omTestingPersistence/OutboxTransaction.cs → ...istence/CustomTestingOutboxTransaction.cs b/...omTestingPersistence/OutboxTransaction.cs → ...istence/CustomTestingOutboxTransaction.cs
@@ -5,22 +5,23 @@ namespace NServiceBus.AcceptanceTesting
     using System.Threading.Tasks;
     using Extensibility;
     using Outbox;
+    using TransactionalSession;
 
-    class OutboxTransaction : IOutboxTransaction
+    sealed class CustomTestingOutboxTransaction : IOutboxTransaction
     {
         public TaskCompletionSource<bool> CommitTaskCompletionSource { get; set; } = null;
 
-        public OutboxTransaction(ContextBag contextBag)
+        public CustomTestingOutboxTransaction(ContextBag contextBag)
         {
             if (contextBag.TryGet(out CustomTestingPersistenceOpenSessionOptions options))
             {
                 CommitTaskCompletionSource = options.TransactionCommitTaskCompletionSource;
             }
 
-            Transaction = new Transaction();
+            Transaction = new AcceptanceTestingTransaction();
         }
 
-        public Transaction Transaction { get; private set; }
+        public AcceptanceTestingTransaction Transaction { get; private set; }
 
         public void Dispose()
         {

diff --git a/src/NServiceBus.TransactionalSession.CustomTestingPersistence/CustomTestingPersistence.cs b/src/NServiceBus.TransactionalSession.CustomTestingPersistence/CustomTestingPersistence.cs
@@ -6,6 +6,6 @@ namespace NServiceBus.AcceptanceTesting
     public class CustomTestingPersistence : PersistenceDefinition
     {
         internal CustomTestingPersistence() =>
-            Supports<StorageType.Outbox>(s => s.EnableFeatureByDefault<OutboxStorage>());
+            Supports<StorageType.Outbox>(s => s.EnableFeatureByDefault<CustomTestingOutboxPersistence>());
     }
 }
diff --git a/...ansactionalSession.CustomTestingPersistence/CustomTestingPersistenceOpenSessionOptions.cs b/...ansactionalSession.CustomTestingPersistence/CustomTestingPersistenceOpenSessionOptions.cs
@@ -1,7 +1,6 @@
-namespace NServiceBus.AcceptanceTesting
+namespace NServiceBus.TransactionalSession
 {
     using System.Threading.Tasks;
-    using TransactionalSession;
 
     public class CustomTestingPersistenceOpenSessionOptions : OpenSessionOptions
     {

diff --git a/...TestingPersistence/SynchronizedStorage.cs → ...ustomTestingSynchronizedStorageFeature.cs b/...TestingPersistence/SynchronizedStorage.cs → ...ustomTestingSynchronizedStorageFeature.cs
@@ -4,15 +4,13 @@ namespace NServiceBus.AcceptanceTesting
     using Microsoft.Extensions.DependencyInjection;
     using Persistence;
 
-    class SynchronizedStorage : Feature
+    sealed class CustomTestingSynchronizedStorageFeature : Feature
     {
-        public SynchronizedStorage()
-        {
-            DependsOn<Features.SynchronizedStorage>();
-        }
+        public CustomTestingSynchronizedStorageFeature() => DependsOn<SynchronizedStorage>();
+
         protected override void Setup(FeatureConfigurationContext context)
         {
-            context.Services.AddScoped<ICompletableSynchronizedStorageSession, StorageSession>();
+            context.Services.AddScoped<ICompletableSynchronizedStorageSession, CustomTestingSynchronizedStorageSession>();
         }
     }
 }
diff --git a/...ustomTestingPersistence/StorageSession.cs → ...ustomTestingSynchronizedStorageSession.cs b/...ustomTestingPersistence/StorageSession.cs → ...ustomTestingSynchronizedStorageSession.cs
@@ -9,16 +9,16 @@ namespace NServiceBus.AcceptanceTesting
     using Persistence;
     using Transport;
 
-    class StorageSession : ICompletableSynchronizedStorageSession
+    sealed class CustomTestingSynchronizedStorageSession : ICompletableSynchronizedStorageSession
     {
-        public Transaction Transaction { get; private set; }
+        public AcceptanceTestingTransaction Transaction { get; private set; }
 
         public void Dispose() => Transaction = null;
 
         public ValueTask<bool> TryOpen(IOutboxTransaction transaction, ContextBag context,
             CancellationToken cancellationToken = default)
         {
-            if (transaction is OutboxTransaction inMemOutboxTransaction)
+            if (transaction is CustomTestingOutboxTransaction inMemOutboxTransaction)
             {
                 Transaction = inMemOutboxTransaction.Transaction;
                 ownsTransaction = false;
@@ -36,7 +36,7 @@ public ValueTask<bool> TryOpen(TransportTransaction transportTransaction, Contex
                 return new ValueTask<bool>(false);
             }
 
-            Transaction = new Transaction();
+            Transaction = new AcceptanceTestingTransaction();
             ambientTransaction.EnlistVolatile(new EnlistmentNotification(Transaction), EnlistmentOptions.None);
             ownsTransaction = true;
             return new ValueTask<bool>(true);
@@ -45,7 +45,7 @@ public ValueTask<bool> TryOpen(TransportTransaction transportTransaction, Contex
         public Task Open(ContextBag contextBag, CancellationToken cancellationToken = default)
         {
             ownsTransaction = true;
-            Transaction = new Transaction();
+            Transaction = new AcceptanceTestingTransaction();
             return Task.CompletedTask;
         }
 
@@ -65,7 +65,7 @@ public Task CompleteAsync(CancellationToken cancellationToken = default)
 
         sealed class EnlistmentNotification : IEnlistmentNotification
         {
-            public EnlistmentNotification(Transaction transaction) => this.transaction = transaction;
+            public EnlistmentNotification(AcceptanceTestingTransaction transaction) => this.transaction = transaction;
 
             public void Prepare(PreparingEnlistment preparingEnlistment)
             {
@@ -90,7 +90,7 @@ public void Rollback(Enlistment enlistment)
 
             public void InDoubt(Enlistment enlistment) => enlistment.Done();
 
-            readonly Transaction transaction;
+            readonly AcceptanceTestingTransaction transaction;
         }
     }
 }