From 488fd63db0c0edea96dd397af13c9bb3141396e4 Mon Sep 17 00:00:00 2001 From: Sumit Ghosh Date: Wed, 20 Oct 2021 17:42:06 +0530 Subject: [PATCH] Apply suggestions from code review Co-authored-by: David Pine --- .../EventBus/EventBusServiceBus/EventBusServiceBus.cs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/BuildingBlocks/EventBus/EventBusServiceBus/EventBusServiceBus.cs b/src/BuildingBlocks/EventBus/EventBusServiceBus/EventBusServiceBus.cs index 6c722b492..fcf28640c 100644 --- a/src/BuildingBlocks/EventBus/EventBusServiceBus/EventBusServiceBus.cs +++ b/src/BuildingBlocks/EventBus/EventBusServiceBus/EventBusServiceBus.cs @@ -121,15 +121,15 @@ public class EventBusServiceBus : IEventBus var messageData = Encoding.UTF8.GetString(message.Body); // Complete the message so that it is not received again. - if (await ProcessEvent(eventName, messageData)) + if (await ProcessEventAsync(eventName, messageData)) { await _serviceBusPersisterConnection.SubscriptionClient.CompleteAsync(message.SystemProperties.LockToken); } }, - new MessageHandlerOptions(ExceptionReceivedHandler) { MaxConcurrentCalls = 10, AutoComplete = false }); + new MessageHandlerOptions(ExceptionReceivedHandlerAsync) { MaxConcurrentCalls = 10, AutoComplete = false }); } - private Task ExceptionReceivedHandler(ExceptionReceivedEventArgs exceptionReceivedEventArgs) + private Task ExceptionReceivedHandlerAsync(ExceptionReceivedEventArgs exceptionReceivedEventArgs) { var ex = exceptionReceivedEventArgs.Exception; var context = exceptionReceivedEventArgs.ExceptionReceivedContext;