Fixed possible null exception

imperugo · imperugo · commit 1a1e87cbbd0d · 2024-08-20T10:51:32.000+02:00
diff --git a/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs b/src/KafkaFlow.Admin/Handlers/PauseConsumerByNameHandler.cs
@@ -16,11 +16,14 @@ public Task Handle(IMessageContext context, PauseConsumerByName message)
     {
         var consumer = _consumerAccessor[message.ConsumerName];
 
+        if(consumer is null)
+            return Task.CompletedTask;
+
         var assignment = consumer.FilterAssigment(message.Topics);
 
         if (assignment.Any())
         {
-            consumer?.Pause(assignment);
+            consumer.Pause(assignment);
         }
 
         return Task.CompletedTask;

Original file line number	Diff line number	Diff line change
`@@ -16,11 +16,14 @@ public Task Handle(IMessageContext context, PauseConsumerByName message)`
`16`	`16`	`{`
`17`	`17`	`var consumer = _consumerAccessor[message.ConsumerName];`
`18`	`18`
	`19`	`+ if(consumer is null)`
	`20`	`+ return Task.CompletedTask;`
	`21`	`+`
`19`	`22`	`var assignment = consumer.FilterAssigment(message.Topics);`
`20`	`23`
`21`	`24`	`if (assignment.Any())`
`22`	`25`	`{`
`23`		`- consumer?.Pause(assignment);`
	`26`	`+ consumer.Pause(assignment);`
`24`	`27`	`}`
`25`	`28`
`26`	`29`	`return Task.CompletedTask;`