Rename message for checking topic existence

leancodepl · Oct 19, 2023 · 7b64178 · 7b64178
1 parent 9ca2cef
commit 7b64178
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/publisher/src/LeanCode.Pipe/Funnel/CheckTopicRecognized.cs b/publisher/src/LeanCode.Pipe/Funnel/CheckTopicRecognized.cs
@@ -1,3 +1,3 @@
 namespace LeanCode.Pipe.Funnel;
 
-public record CheckTopicRecognized(string TopicType);
+public record CheckIfTopicIsRecognized(string TopicType);
diff --git a/publisher/src/LeanCode.Pipe/Funnel/FunnelledService/TopicExistenceChecker.cs b/publisher/src/LeanCode.Pipe/Funnel/FunnelledService/TopicExistenceChecker.cs
@@ -2,7 +2,7 @@
 
 namespace LeanCode.Pipe.Funnel.FunnelledService;
 
-public class TopicExistenceChecker : IConsumer<CheckTopicRecognized>
+public class TopicExistenceChecker : IConsumer<CheckIfTopicIsRecognized>
 {
     private readonly ITopicExtractor topicExtractor;
 
@@ -11,7 +11,7 @@ public TopicExistenceChecker(ITopicExtractor topicExtractor)
         this.topicExtractor = topicExtractor;
     }
 
-    public async Task Consume(ConsumeContext<CheckTopicRecognized> context)
+    public async Task Consume(ConsumeContext<CheckIfTopicIsRecognized> context)
     {
         var topicType = context.Message.TopicType;
 

diff --git a/publisher/src/LeanCode.Pipe/Funnel/Instance/FunnelSubscriptionExecutor.cs b/publisher/src/LeanCode.Pipe/Funnel/Instance/FunnelSubscriptionExecutor.cs
@@ -11,14 +11,14 @@ public class FunnelSubscriptionExecutor : ISubscriptionExecutor
     private readonly FunnelConfiguration configuration;
     private readonly IMemoryCache memoryCache;
     private readonly IScopedClientFactory scopedClientFactory;
-    private readonly IRequestClient<CheckTopicRecognized> checkTopicRecognizedRequestClient;
+    private readonly IRequestClient<CheckIfTopicIsRecognized> checkTopicRecognizedRequestClient;
     private readonly IEndpointNameFormatter? endpointNameFormatter;
 
     public FunnelSubscriptionExecutor(
         FunnelConfiguration configuration,
         IMemoryCache memoryCache,
         IScopedClientFactory scopedClientFactory,
-        IRequestClient<CheckTopicRecognized> checkTopicRecognizedRequestClient
+        IRequestClient<CheckIfTopicIsRecognized> checkTopicRecognizedRequestClient
     )
     {
         this.configuration = configuration;
@@ -31,7 +31,7 @@ public FunnelSubscriptionExecutor(
         FunnelConfiguration configuration,
         IMemoryCache memoryCache,
         IScopedClientFactory scopedClientFactory,
-        IRequestClient<CheckTopicRecognized> checkTopicRecognizedRequestClient,
+        IRequestClient<CheckIfTopicIsRecognized> checkTopicRecognizedRequestClient,
         IEndpointNameFormatter endpointNameFormatter
     )
     {