From a391ba1532709aeb43673434c1e67585015b4f6a Mon Sep 17 00:00:00 2001
From: 丁松杰 <377973147@qq.com>
Date: Fri, 14 Feb 2020 10:09:42 +0800
Subject: [PATCH] event 发送至 eventbus 后 event 在 storage 中的状态修改为 已发送

---
 src/Pole.Core/EventBus/Bus.cs | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/Pole.Core/EventBus/Bus.cs b/src/Pole.Core/EventBus/Bus.cs
index eec7e70..8466a84 100644
--- a/src/Pole.Core/EventBus/Bus.cs
+++ b/src/Pole.Core/EventBus/Bus.cs
@@ -57,7 +57,7 @@ namespace Pole.Core.EventBus
             }
             else
             {
-                var mediumMessage = eventStorage.StoreMessage(eventEntity, Transaction.DbTransaction);
+                var mediumMessage = await eventStorage.StoreMessage(eventEntity, Transaction.DbTransaction);
 
                 if (Transaction.AutoCommit)
                 {
@@ -66,6 +66,9 @@ namespace Pole.Core.EventBus
             }
 
             await producer.Publish(bytes);
+
+            await eventStorage.ChangePublishStateAsync(eventEntity,EventStatus.Published);
+
             return true;
         }
     }
--
libgit2 0.25.0