Skip to content
This repository was archived by the owner on Apr 29, 2022. It is now read-only.

Commit e04e01b

Browse files
author
Anton Vorontsov
committed
Added .ConfigureAwait(false) for more async safeness
1 parent 3c9d95d commit e04e01b

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/RabbitMQ.Client.Core.DependencyInjection/MessageHandlingService.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public async Task HandleMessageReceivingEvent(BasicDeliverEventArgs eventArgs, I
4646
try
4747
{
4848
var matchingRoutes = GetMatchingRoutePatterns(eventArgs.Exchange, eventArgs.RoutingKey);
49-
await ProcessMessage(eventArgs.Exchange, message, queueService, matchingRoutes);
49+
await ProcessMessage(eventArgs.Exchange, message, queueService, matchingRoutes).ConfigureAwait(false);
5050
queueService.Channel.BasicAck(eventArgs.DeliveryTag, false);
5151
_logger.LogInformation(
5252
$"Message processing finished successfully. Acknowledge has been sent with deliveryTag {eventArgs.DeliveryTag}.");
@@ -145,13 +145,13 @@ async Task ProcessMessage(string exchange, string message, IQueueService queueSe
145145
RunMessageHandler(messageHandler, message, orderedContainer.MatchingRoute);
146146
break;
147147
case IAsyncMessageHandler asyncMessageHandler:
148-
await RunAsyncMessageHandler(asyncMessageHandler, message, orderedContainer.MatchingRoute);
148+
await RunAsyncMessageHandler(asyncMessageHandler, message, orderedContainer.MatchingRoute).ConfigureAwait(false);
149149
break;
150150
case INonCyclicMessageHandler nonCyclicMessageHandler:
151151
RunNonCyclicMessageHandler(nonCyclicMessageHandler, message, orderedContainer.MatchingRoute, queueService);
152152
break;
153153
case IAsyncNonCyclicMessageHandler asyncNonCyclicMessageHandler:
154-
await RunAsyncNonCyclicMessageHandler(asyncNonCyclicMessageHandler, message, orderedContainer.MatchingRoute, queueService);
154+
await RunAsyncNonCyclicMessageHandler(asyncNonCyclicMessageHandler, message, orderedContainer.MatchingRoute, queueService).ConfigureAwait(false);
155155
break;
156156
default:
157157
throw new NotSupportedException($"The type {orderedContainer.MessageHandler.GetType()} of message handler is not supported.");

0 commit comments

Comments
 (0)