Skipped pipelines if CloudEvent (#77)

gsoft-inc · Feb 26, 2024 · 498e7d9 · 498e7d9
1 parent b7b37f2
commit 498e7d9
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/...gation.Publishing.ApplicationInsights/ApplicationInsightsPublishingDomainEventBehavior.cs b/...gation.Publishing.ApplicationInsights/ApplicationInsightsPublishingDomainEventBehavior.cs
@@ -14,7 +14,7 @@ public ApplicationInsightsPublishingDomainEventBehavior(TelemetryClient? telemet
 
     public Task HandleAsync(DomainEventWrapperCollection domainEventWrappers, DomainEventsHandlerDelegate next, CancellationToken cancellationToken)
     {
-        return this._telemetryClient == null
+        return this._telemetryClient == null || domainEventWrappers.DomainSchema == EventSchema.CloudEvent
             ? next(domainEventWrappers, cancellationToken)
             : this.HandleWithTelemetry(domainEventWrappers, next, cancellationToken);
     }

diff --git a/src/Workleap.DomainEventPropagation.Publishing/TracingPublishingDomainEventBehavior.cs b/src/Workleap.DomainEventPropagation.Publishing/TracingPublishingDomainEventBehavior.cs
@@ -8,6 +8,12 @@ internal sealed class TracingPublishingDomainEventBehavior : IPublishingDomainEv
 {
     public async Task HandleAsync(DomainEventWrapperCollection domainEventWrappers, DomainEventsHandlerDelegate next, CancellationToken cancellationToken)
     {
+        if (domainEventWrappers.DomainSchema == EventSchema.CloudEvent)
+        {
+            await next(domainEventWrappers, cancellationToken).ConfigureAwait(false);
+            return;
+        }
+
         var activityName = TracingHelper.GetEventGridEventsPublisherActivityName(domainEventWrappers.DomainEventName);
 
         using var activity = TracingHelper.StartProducerActivity(activityName);