Browse Source

#2052 Check if GetLocalEvents() and GetDistributedEvents() returns null.

pull/2079/head
Halil İbrahim Kalkan 7 years ago
parent
commit
28a8cb70e4
  1. 8
      framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/AbpDbContext.cs
  2. 8
      framework/src/Volo.Abp.MongoDB/Volo/Abp/Domain/Repositories/MongoDB/MongoDbRepository.cs

8
framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/AbpDbContext.cs

@ -224,15 +224,15 @@ namespace Volo.Abp.EntityFrameworkCore
return; return;
} }
var localEvents = generatesDomainEventsEntity.GetLocalEvents().ToArray(); var localEvents = generatesDomainEventsEntity.GetLocalEvents()?.ToArray();
if (localEvents.Any()) if (localEvents != null && localEvents.Any())
{ {
changeReport.DomainEvents.AddRange(localEvents.Select(eventData => new DomainEventEntry(entityAsObj, eventData))); changeReport.DomainEvents.AddRange(localEvents.Select(eventData => new DomainEventEntry(entityAsObj, eventData)));
generatesDomainEventsEntity.ClearLocalEvents(); generatesDomainEventsEntity.ClearLocalEvents();
} }
var distributedEvents = generatesDomainEventsEntity.GetDistributedEvents().ToArray(); var distributedEvents = generatesDomainEventsEntity.GetDistributedEvents()?.ToArray();
if (distributedEvents.Any()) if (distributedEvents != null && distributedEvents.Any())
{ {
changeReport.DistributedEvents.AddRange(distributedEvents.Select(eventData => new DomainEventEntry(entityAsObj, eventData))); changeReport.DistributedEvents.AddRange(distributedEvents.Select(eventData => new DomainEventEntry(entityAsObj, eventData)));
generatesDomainEventsEntity.ClearDistributedEvents(); generatesDomainEventsEntity.ClearDistributedEvents();

8
framework/src/Volo.Abp.MongoDB/Volo/Abp/Domain/Repositories/MongoDB/MongoDbRepository.cs

@ -359,8 +359,8 @@ namespace Volo.Abp.Domain.Repositories.MongoDB
return; return;
} }
var localEvents = generatesDomainEventsEntity.GetLocalEvents().ToArray(); var localEvents = generatesDomainEventsEntity.GetLocalEvents()?.ToArray();
if (localEvents.Any()) if (localEvents != null && localEvents.Any())
{ {
foreach (var localEvent in localEvents) foreach (var localEvent in localEvents)
{ {
@ -370,8 +370,8 @@ namespace Volo.Abp.Domain.Repositories.MongoDB
generatesDomainEventsEntity.ClearLocalEvents(); generatesDomainEventsEntity.ClearLocalEvents();
} }
var distributedEvents = generatesDomainEventsEntity.GetDistributedEvents().ToArray(); var distributedEvents = generatesDomainEventsEntity.GetDistributedEvents()?.ToArray();
if (distributedEvents.Any()) if (distributedEvents != null && distributedEvents.Any())
{ {
foreach (var distributedEvent in distributedEvents) foreach (var distributedEvent in distributedEvents)
{ {

Loading…
Cancel
Save