Browse Source
Merge pull request #17458 from abpframework/DistributedEvent
Eliminate duplicate `DistributedEventSent` and `DistributedEventReceived` events.
pull/17459/head
Halil İbrahim Kalkan
3 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
0 additions and
17 deletions
-
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, |
|
|
|
|
