Update DistributedEventBusBase.cs

2 years ago · d49665ca27
1 changed files with 5 additions and 2 deletions
--- a/framework/src/Volo.Abp.EventBus/Volo/Abp/EventBus/Distributed/DistributedEventBusBase.cs
+++ b/framework/src/Volo.Abp.EventBus/Volo/Abp/EventBus/Distributed/DistributedEventBusBase.cs
@ -132,10 +132,13 @@ public abstract class DistributedEventBusBase : EventBusBase, IDistributedEventB
                    Serialize(eventData),
                    Clock.Now
                );
-                if (CorrelationIdProvider.Get() != null)
+
+                var correlationId = CorrelationIdProvider.Get();
+                if (correlationId != null)
                {
-                    outgoingEventInfo.SetCorrelationId(CorrelationIdProvider.Get()!);
+                    outgoingEventInfo.SetCorrelationId(correlationId);
                }
+
                await eventOutbox.EnqueueAsync(outgoingEventInfo);
                return true;
            }