diff --git a/src/BuildingBlocks/EventBus/EventBusServiceBus/EventBusServiceBus.cs b/src/BuildingBlocks/EventBus/EventBusServiceBus/EventBusServiceBus.cs index 6c722b492..df541dc29 100644 --- a/src/BuildingBlocks/EventBus/EventBusServiceBus/EventBusServiceBus.cs +++ b/src/BuildingBlocks/EventBus/EventBusServiceBus/EventBusServiceBus.cs @@ -121,7 +121,7 @@ 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); }