Browse Source

Update AzureDistributedEventBus.cs

pull/10762/head
maliming 5 years ago
committed by GitHub
parent
commit
dbe689323a
No known key found for this signature in database GPG Key ID: 4AEE18F83AFDEB23
  1. 8
      framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AzureDistributedEventBus.cs

8
framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AzureDistributedEventBus.cs

@ -172,21 +172,15 @@ public class AzureDistributedEventBus : DistributedEventBusBase, ISingletonDepen
.Locking(factories => factories.Remove(factory)); .Locking(factories => factories.Remove(factory));
} }
protected override async Task PublishToEventBusAsync(Type eventType, object eventData)
{
await PublishAsync(EventNameAttribute.GetNameOrDefault(eventType), eventData);
}
public override void UnsubscribeAll(Type eventType) public override void UnsubscribeAll(Type eventType)
{ {
GetOrCreateHandlerFactories(eventType) GetOrCreateHandlerFactories(eventType)
.Locking(factories => factories.Clear()); .Locking(factories => factories.Clear());
} }
protected override async Task PublishToEventBusAsync(Type eventType, object eventData) protected override async Task PublishToEventBusAsync(Type eventType, object eventData)
{ {
await PublishAsync(eventType, eventData); await PublishAsync(EventNameAttribute.GetNameOrDefault(eventType), eventData);
} }
protected override void AddToUnitOfWork(IUnitOfWork unitOfWork, UnitOfWorkEventRecord eventRecord) protected override void AddToUnitOfWork(IUnitOfWork unitOfWork, UnitOfWorkEventRecord eventRecord)

Loading…
Cancel
Save