From ec6297efeb976edf8f11b72807117042e2f9ef6c Mon Sep 17 00:00:00 2001 From: "Jeremy D. Miller" Date: Tue, 2 Dec 2025 06:10:23 -0600 Subject: [PATCH] Really fixing the duplicate envelope problem. 5.4.2 --- Directory.Build.props | 2 +- .../Wolverine.Marten/FlushOutgoingMessagesOnCommit.cs | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/Directory.Build.props b/Directory.Build.props index 981fff979..f6c81e9f2 100644 --- a/Directory.Build.props +++ b/Directory.Build.props @@ -11,7 +11,7 @@ 1570;1571;1572;1573;1574;1587;1591;1701;1702;1711;1735;0618 true enable - 5.4.1 + 5.4.2 $(PackageProjectUrl) true true diff --git a/src/Persistence/Wolverine.Marten/FlushOutgoingMessagesOnCommit.cs b/src/Persistence/Wolverine.Marten/FlushOutgoingMessagesOnCommit.cs index 20d29210c..cb5b274a6 100644 --- a/src/Persistence/Wolverine.Marten/FlushOutgoingMessagesOnCommit.cs +++ b/src/Persistence/Wolverine.Marten/FlushOutgoingMessagesOnCommit.cs @@ -36,11 +36,11 @@ public override Task BeforeSaveChangesAsync(IDocumentSession session, Cancellati } // This was buggy in real usage. - else - { - var envelope = Envelope.ForPersistedHandled(_context.Envelope, DateTimeOffset.UtcNow, _context.Runtime.Options.Durability); - session.QueueOperation(new StoreIncomingEnvelope(_messageStore.IncomingFullName, envelope)); - } + // else + // { + // var envelope = Envelope.ForPersistedHandled(_context.Envelope, DateTimeOffset.UtcNow, _context.Runtime.Options.Durability); + // session.QueueOperation(new StoreIncomingEnvelope(_messageStore.IncomingFullName, envelope)); + // } }