删除不必要的代码

bf389e5b · 丁松杰 · d0e3d7c6 · bf389e5b
Commit bf389e5b authored Feb 14, 2020 by 丁松杰
Showing with 3 additions and 5 deletions
src/Pole.Core/EventBus/Bus.cs
--- a/src/Pole.Core/EventBus/Bus.cs
+++ b/src/Pole.Core/EventBus/Bus.cs
@@ -57,13 +57,11 @@ namespace Pole.Core.EventBus
            }
            else
            {
-                var transaction = (IDbTransactionAdapter)Transaction;
+                var mediumMessage = eventStorage.StoreMessage(eventEntity, Transaction.DbTransaction);

-                var mediumMessage = eventStorage.StoreMessage(eventEntity, transaction.DbTransaction);
-
-                if (transaction.AutoCommit)
+                if (Transaction.AutoCommit)
                {
-                    await transaction.CommitAsync();
+                    await Transaction.CommitAsync();
                }
            }