Skip to content

Commit ada5f9d

Browse files
committed
Ripping out the check on owner != 0 and Incoming. There is a valid usage of that. Closes GH-1856
1 parent 4263560 commit ada5f9d

2 files changed

Lines changed: 1 addition & 6 deletions

File tree

src/Persistence/Wolverine.RDBMS/MessageDatabase.Incoming.cs

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -133,12 +133,6 @@ public async Task StoreIncomingAsync(Envelope envelope)
133133
{
134134
if (HasDisposed) return;
135135

136-
if (envelope.OwnerId == TransportConstants.AnyNode && envelope.Status == EnvelopeStatus.Incoming)
137-
{
138-
throw new ArgumentOutOfRangeException(nameof(Envelope),
139-
"Erroneous persistence of an incoming envelope to 'any' node");
140-
}
141-
142136
var builder = ToCommandBuilder();
143137
DatabasePersistence.BuildIncomingStorageCommand(this, builder, envelope);
144138

src/Wolverine/Transports/Local/DurableLocalQueue.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -204,6 +204,7 @@ private async Task storeAndEnqueueAsync(Envelope envelope)
204204
{
205205
try
206206
{
207+
envelope.OwnerId = _settings.AssignedNodeNumber;
207208
await _inbox.StoreIncomingAsync(envelope);
208209
envelope.WasPersistedInInbox = true;
209210
}

0 commit comments

Comments
 (0)