Browse Source
Merge branch 'abpframework:dev' into dev
pull/12869/head
Nader Javid
4 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
10 additions and
2 deletions
-
framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AzureDistributedEventBus.cs
|
|
|
@ -108,9 +108,17 @@ public class AzureDistributedEventBus : DistributedEventBusBase, ISingletonDepen |
|
|
|
|
|
|
|
foreach (var outgoingEvent in outgoingEventArray) |
|
|
|
{ |
|
|
|
if (!messageBatch.TryAddMessage(new ServiceBusMessage(outgoingEvent.EventData) { Subject = outgoingEvent.EventName })) |
|
|
|
var message = new ServiceBusMessage(outgoingEvent.EventData) { Subject = outgoingEvent.EventName }; |
|
|
|
|
|
|
|
if (message.MessageId.IsNullOrWhiteSpace()) |
|
|
|
{ |
|
|
|
message.MessageId = outgoingEvent.Id.ToString(); |
|
|
|
} |
|
|
|
|
|
|
|
if (!messageBatch.TryAddMessage(message)) |
|
|
|
{ |
|
|
|
throw new AbpException("The message is too large to fit in the batch. Set AbpEventBusBoxesOptions.OutboxWaitingEventMaxCount to reduce the number"); |
|
|
|
throw new AbpException( |
|
|
|
"The message is too large to fit in the batch. Set AbpEventBusBoxesOptions.OutboxWaitingEventMaxCount to reduce the number"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|