Fix issue #32

EL Aisati Ahmed · EL Aisati Ahmed · commit 302b4e74bdd0 · 2020-03-28T21:23:21.000+01:00
diff --git a/src/RabbitMQ.Client.Core.DependencyInjection/MessageHandlingService.cs b/src/RabbitMQ.Client.Core.DependencyInjection/MessageHandlingService.cs
@@ -47,7 +47,7 @@ public async Task HandleMessageReceivingEvent(BasicDeliverEventArgs eventArgs, I
             {
                 var matchingRoutes = GetMatchingRoutePatterns(eventArgs.Exchange, eventArgs.RoutingKey);
                 await ProcessMessage(eventArgs.Exchange, message, queueService, matchingRoutes).ConfigureAwait(false);
-                queueService.Channel.BasicAck(eventArgs.DeliveryTag, false);
+                queueService.ConsumingChannel.BasicAck(eventArgs.DeliveryTag, false);
                 _logger.LogInformation(
                     $"Message processing finished successfully. Acknowledge has been sent with deliveryTag {eventArgs.DeliveryTag}.");
             }
@@ -58,7 +58,7 @@ public async Task HandleMessageReceivingEvent(BasicDeliverEventArgs eventArgs, I
                     exception,
                     $"An error occurred while processing received message with the delivery tag {eventArgs.DeliveryTag}.");
 
-                queueService.Channel.BasicAck(eventArgs.DeliveryTag, false);
+                queueService.ConsumingChannel.BasicAck(eventArgs.DeliveryTag, false);
 
                 if (eventArgs.BasicProperties.Headers is null)
                 {

Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ public async Task HandleMessageReceivingEvent(BasicDeliverEventArgs eventArgs, I`
`47`	`47`	`{`
`48`	`48`	`var matchingRoutes = GetMatchingRoutePatterns(eventArgs.Exchange, eventArgs.RoutingKey);`
`49`	`49`	`await ProcessMessage(eventArgs.Exchange, message, queueService, matchingRoutes).ConfigureAwait(false);`
`50`		`- queueService.Channel.BasicAck(eventArgs.DeliveryTag, false);`
	`50`	`+ queueService.ConsumingChannel.BasicAck(eventArgs.DeliveryTag, false);`
`51`	`51`	`_logger.LogInformation(`
`52`	`52`	`$"Message processing finished successfully. Acknowledge has been sent with deliveryTag {eventArgs.DeliveryTag}.");`
`53`	`53`	`}`
`@@ -58,7 +58,7 @@ public async Task HandleMessageReceivingEvent(BasicDeliverEventArgs eventArgs, I`
`58`	`58`	`exception,`
`59`	`59`	`$"An error occurred while processing received message with the delivery tag {eventArgs.DeliveryTag}.");`
`60`	`60`
`61`		`- queueService.Channel.BasicAck(eventArgs.DeliveryTag, false);`
	`61`	`+ queueService.ConsumingChannel.BasicAck(eventArgs.DeliveryTag, false);`
`62`	`62`
`63`	`63`	`if (eventArgs.BasicProperties.Headers is null)`
`64`	`64`	`{`