Fixed native scheduling conditional in MessageContext

Kristopher Akins · jeremydmiller · commit df4518cf1c8e · 2025-11-05T15:44:10.000-06:00
diff --git a/src/Wolverine/Runtime/MessageContext.cs b/src/Wolverine/Runtime/MessageContext.cs
@@ -61,18 +61,18 @@ public async Task FlushOutgoingMessagesAsync()
             {
                 if (envelope.IsScheduledForLater(DateTimeOffset.UtcNow))
                 {
-                    if (envelope.Sender!.SupportsNativeScheduledSend)
+                    if (!envelope.Sender!.IsDurable)
                     {
-                        await sendEnvelopeAsync(envelope);
-                    }
-                    else if (!envelope.Sender!.IsDurable)
-                    {
-                        Runtime.ScheduleLocalExecutionInMemory(envelope.ScheduledTime!.Value, envelope);
-                    }
-                    else
-                    {
-                        await sendEnvelopeAsync(envelope);
+                        if (envelope.Sender!.SupportsNativeScheduledSend)
+                        {
+                            await sendEnvelopeAsync(envelope);
+                        }
+                        else
+                        {
+                            Runtime.ScheduleLocalExecutionInMemory(envelope.ScheduledTime!.Value, envelope);
+                        }
                     }
+
                     // If NullMessageStore, then we're calling a different Send method that is marking the message
                     if (Runtime.Storage is not NullMessageStore)
                     {

Original file line number	Diff line number	Diff line change
`@@ -61,18 +61,18 @@ public async Task FlushOutgoingMessagesAsync()`
`61`	`61`	`{`
`62`	`62`	`if (envelope.IsScheduledForLater(DateTimeOffset.UtcNow))`
`63`	`63`	`{`
`64`		`- if (envelope.Sender!.SupportsNativeScheduledSend)`
	`64`	`+ if (!envelope.Sender!.IsDurable)`
`65`	`65`	`{`
`66`		`- await sendEnvelopeAsync(envelope);`
`67`		`- }`
`68`		`- else if (!envelope.Sender!.IsDurable)`
`69`		`- {`
`70`		`- Runtime.ScheduleLocalExecutionInMemory(envelope.ScheduledTime!.Value, envelope);`
`71`		`- }`
`72`		`- else`
`73`		`- {`
`74`		`- await sendEnvelopeAsync(envelope);`
	`66`	`+ if (envelope.Sender!.SupportsNativeScheduledSend)`
	`67`	`+ {`
	`68`	`+ await sendEnvelopeAsync(envelope);`
	`69`	`+ }`
	`70`	`+ else`
	`71`	`+ {`
	`72`	`+ Runtime.ScheduleLocalExecutionInMemory(envelope.ScheduledTime!.Value, envelope);`
	`73`	`+ }`
`75`	`74`	`}`
	`75`	`+`
`76`	`76`	`// If NullMessageStore, then we're calling a different Send method that is marking the message`
`77`	`77`	`if (Runtime.Storage is not NullMessageStore)`
`78`	`78`	`{`