diff --git a/src/EntityDb.Common/Entities/EntityRepository.cs b/src/EntityDb.Common/Entities/EntityRepository.cs
index a7db31fd..e3448fc9 100644
--- a/src/EntityDb.Common/Entities/EntityRepository.cs
+++ b/src/EntityDb.Common/Entities/EntityRepository.cs
@@ -57,14 +57,14 @@ public async Task<TEntity> GetSnapshot(Pointer entityPointer, CancellationToken
 
     public async Task<bool> PutTransaction(ITransaction transaction, CancellationToken cancellationToken = default)
     {
-        try
-        {
-            return await TransactionRepository.PutTransaction(transaction, cancellationToken);
-        }
-        finally
+        var success = await TransactionRepository.PutTransaction(transaction, cancellationToken);
+
+        if (success)
         {
             Publish(transaction);
         }
+
+        return success;
     }
 
     public override async ValueTask DisposeAsync()