event 发送至 eventbus 后 event 在 storage 中的状态修改为 已发送

src/Pole.Core/EventBus/Bus.cs

@@ -57,7 +57,7 @@ namespace Pole.Core.EventBus
             }
             }
             else
             else
             {
             {
-                var mediumMessage = eventStorage.StoreMessage(eventEntity, Transaction.DbTransaction);
+                var mediumMessage = await eventStorage.StoreMessage(eventEntity, Transaction.DbTransaction);
 
 
                 if (Transaction.AutoCommit)
                 if (Transaction.AutoCommit)
                 {
                 {
@@ -66,6 +66,9 @@ namespace Pole.Core.EventBus
             }
             }
 
 
             await producer.Publish(bytes);
             await producer.Publish(bytes);
+
+            await eventStorage.ChangePublishStateAsync(eventEntity,EventStatus.Published);
+
             return true;
             return true;
         }
         }
     }
     }