OutboxDispatcher moved from ctor to Init method of UnitOfWork

swisschain · Aug 12, 2020 · e0efc1a · e0efc1a
1 parent 0b03c4c
commit e0efc1a
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 13 deletions.
diff --git a/src/Swisschain.Extensions.Idempotency/IUnitOfWork.cs b/src/Swisschain.Extensions.Idempotency/IUnitOfWork.cs
@@ -10,7 +10,9 @@ public interface IUnitOfWork : IAsyncDisposable
         bool IsRolledBack { get; }
         Outbox Outbox { get; }
 
-        Task Init(IOutboxWriteRepository outboxWriteRepository, Outbox outbox);
+        Task Init(IOutboxDispatcher defaultOutboxDispatcher,
+            IOutboxWriteRepository outboxWriteRepository, 
+            Outbox outbox);
 
         /// <summary>
         /// Closes the <see cref="Outbox"/> and commits unit of work transaction

diff --git a/src/Swisschain.Extensions.Idempotency/UnitOfWorkBase.cs b/src/Swisschain.Extensions.Idempotency/UnitOfWorkBase.cs
@@ -5,12 +5,7 @@ namespace Swisschain.Extensions.Idempotency
 {
     public abstract class UnitOfWorkBase : IUnitOfWork
     {
-        private readonly IOutboxDispatcher _defaultOutboxDispatcher;
-
-        public UnitOfWorkBase(IOutboxDispatcher defaultOutboxDispatcher)
-        {
-            _defaultOutboxDispatcher = defaultOutboxDispatcher;
-        }
+        private IOutboxDispatcher _defaultOutboxDispatcher;
 
         public IOutboxWriteRepository OutboxWriteRepository { get; private set; }
         public bool IsCommitted { get; private set; }
@@ -21,9 +16,12 @@ public UnitOfWorkBase(IOutboxDispatcher defaultOutboxDispatcher)
         protected abstract Task RollbackImpl();
         protected abstract ValueTask DisposeAsync(bool disposing);
 
-        public Task Init(IOutboxWriteRepository outboxWriteRepository,
+        public Task Init(IOutboxDispatcher defaultOutboxDispatcher,
+            IOutboxWriteRepository outboxWriteRepository,
             Outbox outbox)
         {
+            _defaultOutboxDispatcher = defaultOutboxDispatcher;
+
             OutboxWriteRepository = outboxWriteRepository;
             Outbox = outbox;
 

diff --git a/tests/Tests/ExampleUnitOfWork.cs b/tests/Tests/ExampleUnitOfWork.cs
@@ -5,11 +5,6 @@ namespace Tests
 {
     public class ExampleUnitOfWork : UnitOfWorkBase
     {
-        public ExampleUnitOfWork(IOutboxDispatcher defaultOutboxDispatcher) :
-            base(defaultOutboxDispatcher)
-        {
-        }
-
         protected override Task CommitImpl()
         {
             throw new System.NotImplementedException();