Add generic scoped filter type to configuration JSON

RJSonnenberg · May 22, 2023 · a4163e8 · a4163e8
1 parent 967a9d0
commit a4163e8
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 0 deletions.
diff --git a/src/MassTransit/Middleware/ScopedCompensateFilter.cs b/src/MassTransit/Middleware/ScopedCompensateFilter.cs
@@ -2,6 +2,7 @@ namespace MassTransit.Middleware
 {
     using System.Threading.Tasks;
     using DependencyInjection;
+    using Metadata;
 
 
     public class ScopedCompensateFilter<TActivity, TArguments, TFilter> :
@@ -29,6 +30,7 @@ public async Task Send(CompensateContext<TArguments> context, IPipe<CompensateCo
         public void Probe(ProbeContext context)
         {
             var scope = context.CreateFilterScope("scopedFilter");
+            scope.Add("filter", TypeMetadataCache<TFilter>.ShortName);
 
             _scopeProvider.Probe(scope);
         }

diff --git a/src/MassTransit/Middleware/ScopedConsumeFilter.cs b/src/MassTransit/Middleware/ScopedConsumeFilter.cs
@@ -2,6 +2,7 @@ namespace MassTransit.Middleware
 {
     using System.Threading.Tasks;
     using DependencyInjection;
+    using Metadata;
 
 
     public class ScopedConsumeFilter<T, TFilter> :
@@ -28,6 +29,7 @@ public async Task Send(ConsumeContext<T> context, IPipe<ConsumeContext<T>> next)
         public void Probe(ProbeContext context)
         {
             var scope = context.CreateFilterScope("scopedFilter");
+            scope.Add("filter", TypeMetadataCache<TFilter>.ShortName);
 
             _scopeProvider.Probe(scope);
         }

diff --git a/src/MassTransit/Middleware/ScopedExecuteFilter.cs b/src/MassTransit/Middleware/ScopedExecuteFilter.cs
@@ -2,6 +2,7 @@ namespace MassTransit.Middleware
 {
     using System.Threading.Tasks;
     using DependencyInjection;
+    using Metadata;
 
 
     public class ScopedExecuteFilter<TActivity, TArguments, TFilter> :
@@ -29,6 +30,7 @@ public async Task Send(ExecuteContext<TArguments> context, IPipe<ExecuteContext<
         public void Probe(ProbeContext context)
         {
             var scope = context.CreateFilterScope("scopedFilter");
+            scope.Add("filter", TypeMetadataCache<TFilter>.ShortName);
 
             _scopeProvider.Probe(scope);
         }