Fixed an issue where the PublishDelay synchronization method did not wait internally.

yang-xiaodong · yang-xiaodong · commit 14e6a516a651 · 2024-05-07T10:36:42.000+08:00
diff --git a/src/DotNetCore.CAP/Internal/ICapPublisher.Default.cs b/src/DotNetCore.CAP/Internal/ICapPublisher.Default.cs
@@ -102,7 +102,7 @@ public void Publish<T>(string name, T? value, IDictionary<string, string?> heade
 
     public void PublishDelay<T>(TimeSpan delayTime, string name, T? value, IDictionary<string, string?> headers)
     {
-        PublishDelayAsync(delayTime, name, value, headers).ConfigureAwait(false);
+        PublishDelayAsync(delayTime, name, value, headers).ConfigureAwait(false).GetAwaiter().GetResult();
     }
 
     public void PublishDelay<T>(TimeSpan delayTime, string name, T? value, string? callbackName = null)

Original file line number	Diff line number	Diff line change
`@@ -102,7 +102,7 @@ public void Publish<T>(string name, T? value, IDictionary<string, string?> heade`
`102`	`102`
`103`	`103`	`public void PublishDelay<T>(TimeSpan delayTime, string name, T? value, IDictionary<string, string?> headers)`
`104`	`104`	`{`
`105`		`- PublishDelayAsync(delayTime, name, value, headers).ConfigureAwait(false);`
	`105`	`+ PublishDelayAsync(delayTime, name, value, headers).ConfigureAwait(false).GetAwaiter().GetResult();`
`106`	`106`	`}`
`107`	`107`
`108`	`108`	`public void PublishDelay<T>(TimeSpan delayTime, string name, T? value, string? callbackName = null)`