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,