Merge pull request #21468 from abpframework/CorrlationIdv8

Skip to set `CorrelationId ` if current value is `null`.

Author: maliming

framework/src/Volo.Abp.EventBus/Volo/Abp/EventBus/Distributed/DistributedEventBusBase.cs

@@ -133,7 +133,10 @@ protected virtual async Task<bool> AddToOutboxAsync(Type eventType, object event
                     Serialize(eventData),
                     Clock.Now
                 );
-                outgoingEventInfo.SetCorrelationId(CorrelationIdProvider.Get()!);
+                if (CorrelationIdProvider.Get() != null)
+                {
+                    outgoingEventInfo.SetCorrelationId(CorrelationIdProvider.Get()!);
+                }
                 await eventOutbox.EnqueueAsync(outgoingEventInfo);
                 return true;
             }

framework/src/Volo.Abp.Http.Client/Volo/Abp/Http/Client/ClientProxying/ClientProxyBase.cs

@@ -310,7 +310,11 @@ protected virtual void AddHeaders(
         }
 
         //CorrelationId
-        requestMessage.Headers.Add(AbpCorrelationIdOptions.Value.HttpHeaderName, CorrelationIdProvider.Get());
+        var correlationId = CorrelationIdProvider.Get();
+        if (correlationId != null)
+        {
+            requestMessage.Headers.Add(AbpCorrelationIdOptions.Value.HttpHeaderName, correlationId);
+        }
 
         //TenantId
         if (CurrentTenant.Id.HasValue)

framework/src/Volo.Abp.Http.Client/Volo/Abp/Http/Client/DynamicProxying/ApiDescriptionFinder.cs

@@ -126,7 +126,11 @@ protected virtual async Task<ApplicationApiDescriptionModel> GetApiDescriptionFr
     protected virtual void AddHeaders(HttpRequestMessage requestMessage)
     {
         //CorrelationId
-        requestMessage.Headers.Add(AbpCorrelationIdOptions.HttpHeaderName, CorrelationIdProvider.Get());
+        var correlationId = CorrelationIdProvider.Get();
+        if (correlationId != null)
+        {
+            requestMessage.Headers.Add(AbpCorrelationIdOptions.HttpHeaderName, correlationId);
+        }
 
         //TenantId
         if (CurrentTenant.Id.HasValue)