Update AzureDistributedEventBus.cs

5 years ago · c39ee0b6a2
1 changed files with 5 additions and 0 deletions
--- a/framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AzureDistributedEventBus.cs
+++ b/framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AzureDistributedEventBus.cs
@ -77,6 +77,11 @@ namespace Volo.Abp.EventBus.Azure
                return;
            }

+            if (await AddToInboxAsync(message.MessageId, eventName, eventType, message.Body.ToArray()))
+            {
+                return;
+            }
+
            var eventData = _serializer.Deserialize(message.Body.ToArray(), eventType);

            await TriggerHandlersAsync(eventType, eventData);