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;
         }
     }