|
|
@ -71,6 +71,10 @@ public class AzureDistributedEventBus : DistributedEventBusBase, ISingletonDepen |
|
|
private async Task ProcessEventAsync(ServiceBusReceivedMessage message) |
|
|
private async Task ProcessEventAsync(ServiceBusReceivedMessage message) |
|
|
{ |
|
|
{ |
|
|
var eventName = message.Subject; |
|
|
var eventName = message.Subject; |
|
|
|
|
|
if (eventName == null) |
|
|
|
|
|
{ |
|
|
|
|
|
return; |
|
|
|
|
|
} |
|
|
var eventType = _eventTypes.GetOrDefault(eventName); |
|
|
var eventType = _eventTypes.GetOrDefault(eventName); |
|
|
if (eventType == null) |
|
|
if (eventType == null) |
|
|
{ |
|
|
{ |
|
|
|