diff --git a/src/MaksIT.Dapr/DaprService.cs b/src/MaksIT.Dapr/DaprService.cs index 67be652..6dd6242 100644 --- a/src/MaksIT.Dapr/DaprService.cs +++ b/src/MaksIT.Dapr/DaprService.cs @@ -39,7 +39,17 @@ public class DaprService : IDaprPublisherService, IDaprStateStoreService { /// public async Task PublishEventAsync(string pubSubName, string topicName, string payload) { try { - await _client.PublishEventAsync(pubSubName, topicName, payload); + + var traceId = System.Diagnostics.Activity.Current?.TraceId.ToString(); + + if (!string.IsNullOrEmpty(traceId)) { + var metadata = new Dictionary { ["traceid"] = traceId }; + await _client.PublishEventAsync(pubSubName, topicName, payload, metadata); + } + else { + await _client.PublishEventAsync(pubSubName, topicName, payload); + } + return Result.Ok(); } catch (Exception ex) { diff --git a/src/MaksIT.Dapr/MaksIT.Dapr.csproj b/src/MaksIT.Dapr/MaksIT.Dapr.csproj index 6fa6d68..3c87dcc 100644 --- a/src/MaksIT.Dapr/MaksIT.Dapr.csproj +++ b/src/MaksIT.Dapr/MaksIT.Dapr.csproj @@ -7,7 +7,7 @@ MaksIT.Dapr - 1.0.6 + 1.0.7 Maksym Sadovnychyy MAKS-IT MaksIT.Dapr