Skip to content

Commit

Permalink
It got worse...
Browse files Browse the repository at this point in the history
  • Loading branch information
alexeyzimarev committed Jun 15, 2022
1 parent 35cf1f6 commit 82b8f6c
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ public static class SubscriptionActivity {
IMessageConsumeContext context,
IEnumerable<KeyValuePair<string, object?>>? tags = null
) {
context.ParentContext ??= GetParentContext(context);
context.ParentContext = GetParentContext(context);
var activity = Create(name, activityKind, context.ParentContext, tags);
return activity?.SetContextTags(context);
}
Expand Down Expand Up @@ -44,6 +44,8 @@ public static class SubscriptionActivity {
}

static ActivityContext? GetParentContext(IBaseConsumeContext context) {
if (Activity.Current != null) return Activity.Current.Context;

if (context.Items.TryGetItem<Activity>(ContextItemKeys.Activity, out var parentActivity)) {
return parentActivity?.Context;
}
Expand Down

0 comments on commit 82b8f6c

Please sign in to comment.