Browse Source

Make the Azure bus publishes many from outbox with MessageId

pull/12811/head
gdlcf88 4 years ago
parent
commit
90c828c83a
  1. 9
      framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AzureDistributedEventBus.cs

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

@ -108,9 +108,14 @@ 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) {
MessageId = outgoingEvent.Id.ToString(), Subject = outgoingEvent.EventName
};
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");
}
}

Loading…
Cancel
Save