From d54d3e92f12e7ef93f5b37e9f7cdd06d2edd1592 Mon Sep 17 00:00:00 2001 From: "Jeremy D. Miller" Date: Sat, 22 Nov 2025 15:33:33 -0600 Subject: [PATCH] Ripping out the check on owner != 0 and Incoming. There is a valid usage of that. Closes GH-1856 --- src/Persistence/Wolverine.RDBMS/MessageDatabase.Incoming.cs | 6 ------ src/Wolverine/Transports/Local/DurableLocalQueue.cs | 1 + 2 files changed, 1 insertion(+), 6 deletions(-) diff --git a/src/Persistence/Wolverine.RDBMS/MessageDatabase.Incoming.cs b/src/Persistence/Wolverine.RDBMS/MessageDatabase.Incoming.cs index d1170a99a..56316b002 100644 --- a/src/Persistence/Wolverine.RDBMS/MessageDatabase.Incoming.cs +++ b/src/Persistence/Wolverine.RDBMS/MessageDatabase.Incoming.cs @@ -133,12 +133,6 @@ public async Task StoreIncomingAsync(Envelope envelope) { if (HasDisposed) return; - if (envelope.OwnerId == TransportConstants.AnyNode && envelope.Status == EnvelopeStatus.Incoming) - { - throw new ArgumentOutOfRangeException(nameof(Envelope), - "Erroneous persistence of an incoming envelope to 'any' node"); - } - var builder = ToCommandBuilder(); DatabasePersistence.BuildIncomingStorageCommand(this, builder, envelope); diff --git a/src/Wolverine/Transports/Local/DurableLocalQueue.cs b/src/Wolverine/Transports/Local/DurableLocalQueue.cs index 909345953..5acf965d0 100644 --- a/src/Wolverine/Transports/Local/DurableLocalQueue.cs +++ b/src/Wolverine/Transports/Local/DurableLocalQueue.cs @@ -204,6 +204,7 @@ private async Task storeAndEnqueueAsync(Envelope envelope) { try { + envelope.OwnerId = _settings.AssignedNodeNumber; await _inbox.StoreIncomingAsync(envelope); envelope.WasPersistedInInbox = true; }