diff --git a/src/Cnblogs.Architecture.Ddd.EventBus.Dapr/DaprEventBus.cs b/src/Cnblogs.Architecture.Ddd.EventBus.Dapr/DaprEventBus.cs index 952aca5..a107de6 100644 --- a/src/Cnblogs.Architecture.Ddd.EventBus.Dapr/DaprEventBus.cs +++ b/src/Cnblogs.Architecture.Ddd.EventBus.Dapr/DaprEventBus.cs @@ -51,11 +51,11 @@ public async Task PublishAsync(string eventName, TEvent @event) eventName, @event, @event.TraceId ?? @event.Id); - var eventToSend = @event.TraceId = TraceId; + @event.TraceId = TraceId; await _daprClient.PublishEventAsync( DaprOptions.PubSubName, DaprUtils.GetDaprTopicName(_daprOptions.AppName, eventName), - eventToSend); + @event); } ///