(feature): add traceI id if available
This commit is contained in:
parent
4a8efde246
commit
5327b19e04
@ -39,7 +39,17 @@ public class DaprService : IDaprPublisherService, IDaprStateStoreService {
|
|||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
public async Task<Result> PublishEventAsync(string pubSubName, string topicName, string payload) {
|
public async Task<Result> PublishEventAsync(string pubSubName, string topicName, string payload) {
|
||||||
try {
|
try {
|
||||||
|
|
||||||
|
var traceId = System.Diagnostics.Activity.Current?.TraceId.ToString();
|
||||||
|
|
||||||
|
if (!string.IsNullOrEmpty(traceId)) {
|
||||||
|
var metadata = new Dictionary<string, string> { ["traceid"] = traceId };
|
||||||
|
await _client.PublishEventAsync(pubSubName, topicName, payload, metadata);
|
||||||
|
}
|
||||||
|
else {
|
||||||
await _client.PublishEventAsync(pubSubName, topicName, payload);
|
await _client.PublishEventAsync(pubSubName, topicName, payload);
|
||||||
|
}
|
||||||
|
|
||||||
return Result.Ok();
|
return Result.Ok();
|
||||||
}
|
}
|
||||||
catch (Exception ex) {
|
catch (Exception ex) {
|
||||||
|
|||||||
@ -7,7 +7,7 @@
|
|||||||
|
|
||||||
<!-- NuGet package metadata -->
|
<!-- NuGet package metadata -->
|
||||||
<PackageId>MaksIT.Dapr</PackageId>
|
<PackageId>MaksIT.Dapr</PackageId>
|
||||||
<Version>1.0.6</Version>
|
<Version>1.0.7</Version>
|
||||||
<Authors>Maksym Sadovnychyy</Authors>
|
<Authors>Maksym Sadovnychyy</Authors>
|
||||||
<Company>MAKS-IT</Company>
|
<Company>MAKS-IT</Company>
|
||||||
<Product>MaksIT.Dapr</Product>
|
<Product>MaksIT.Dapr</Product>
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user