From c04a509607a6ffb8e2ae6b314fe8a39bb1ced749 Mon Sep 17 00:00:00 2001
From: maliming <malimings@gmail.com>
Date: Thu, 24 Aug 2023 09:16:18 +0800
Subject: [PATCH] Eliminate duplicate DistributedEventSent and
 DistributedEventReceived events.

Resolve #17451
---
 .../Distributed/DistributedEventBusBase.cs      | 17 -----------------
 1 file changed, 17 deletions(-)

diff --git a/framework/src/Volo.Abp.EventBus/Volo/Abp/EventBus/Distributed/DistributedEventBusBase.cs b/framework/src/Volo.Abp.EventBus/Volo/Abp/EventBus/Distributed/DistributedEventBusBase.cs
index 2ca5c85bb0..670aa6ef23 100644
--- a/framework/src/Volo.Abp.EventBus/Volo/Abp/EventBus/Distributed/DistributedEventBusBase.cs
+++ b/framework/src/Volo.Abp.EventBus/Volo/Abp/EventBus/Distributed/DistributedEventBusBase.cs
@@ -127,13 +127,6 @@ public abstract class DistributedEventBusBase : EventBusBase, IDistributedEventB
 
                 await OnAddToOutboxAsync(eventName, eventType, eventData);
 
-                await TriggerDistributedEventSentAsync(new DistributedEventSent()
-                {
-                    Source = DistributedEventSource.Direct,
-                    EventName = eventName,
-                    EventData = eventData
-                });
-
                 var outgoingEventInfo = new OutgoingEventInfo(
                     GuidGenerator.Create(),
                     eventName,
@@ -183,16 +176,6 @@ public abstract class DistributedEventBusBase : EventBusBase, IDistributedEventB
                         }
                     }
 
-                    using (CorrelationIdProvider.Change(correlationId))
-                    {
-                        await TriggerDistributedEventReceivedAsync(new DistributedEventReceived
-                        {
-                            Source = DistributedEventSource.Direct,
-                            EventName = EventNameAttribute.GetNameOrDefault(eventType),
-                            EventData = eventData
-                        });
-                    }
-
                     var incomingEventInfo = new IncomingEventInfo(
                         GuidGenerator.Create(),
                         messageId,