Fixed the owner id assignment in envelopes being stored by EF Core tr…

…ansactions. Closes GH-587. Bumps to 1.8.3.

Directory.Build.props

@@ -11,7 +11,7 @@
         <TargetFrameworks>net6.0;net7.0</TargetFrameworks>
         <NoWarn>1570;1571;1572;1573;1574;1587;1591;1701;1702;1711;1735;0618</NoWarn>
         <ImplicitUsings>true</ImplicitUsings>
-        <Version>1.8.2</Version>
+        <Version>1.8.3</Version>
         <RepositoryUrl>$(PackageProjectUrl)</RepositoryUrl>
         <PublishRepositoryUrl>true</PublishRepositoryUrl>
         <EmbedUntrackedSources>true</EmbedUntrackedSources>

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

@@ -2,6 +2,7 @@
 using Weasel.Core;
 using Wolverine.Persistence.Durability;
 using Wolverine.Runtime.Serialization;
+using Wolverine.Transports;
 
 namespace Wolverine.RDBMS;
 
@@ -70,6 +71,12 @@ public Task IncrementIncomingEnvelopeAttemptsAsync(Envelope envelope)
 
     public async Task StoreIncomingAsync(Envelope envelope)
     {
+        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);
 

src/Wolverine/Runtime/Routing/MessageRoute.cs

@@ -82,6 +82,10 @@ public Envelope CreateForSending(object message, DeliveryOptions? options, ISend
                 return envelope.ForScheduledSend(localDurableQueue);
             }
         }
+        else
+        {
+            envelope.OwnerId = runtime.Options.Durability.AssignedNodeNumber;
+        }
 
         return envelope;
     }