diff --git a/framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/DistributedEvents/IncomingEventRecord.cs b/framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/DistributedEvents/IncomingEventRecord.cs index 6d151851c4..6cb37a72d5 100644 --- a/framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/DistributedEvents/IncomingEventRecord.cs +++ b/framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/DistributedEvents/IncomingEventRecord.cs @@ -44,6 +44,10 @@ public class IncomingEventRecord : ExtraProperties = new ExtraPropertyDictionary(); this.SetDefaultsForExtraProperties(); + foreach (var property in eventInfo.ExtraProperties) + { + this.SetProperty(property.Key, property.Value); + } } public IncomingEventInfo ToIncomingEventInfo() diff --git a/framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/DistributedEvents/OutgoingEventRecord.cs b/framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/DistributedEvents/OutgoingEventRecord.cs index 163e90e26d..7272c9ac30 100644 --- a/framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/DistributedEvents/OutgoingEventRecord.cs +++ b/framework/src/Volo.Abp.EntityFrameworkCore/Volo/Abp/EntityFrameworkCore/DistributedEvents/OutgoingEventRecord.cs @@ -37,6 +37,10 @@ public class OutgoingEventRecord : ExtraProperties = new ExtraPropertyDictionary(); this.SetDefaultsForExtraProperties(); + foreach (var property in eventInfo.ExtraProperties) + { + this.SetProperty(property.Key, property.Value); + } } public OutgoingEventInfo ToOutgoingEventInfo() diff --git a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IncomingEventRecord.cs b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IncomingEventRecord.cs index 4b66c58595..a48492d1da 100644 --- a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IncomingEventRecord.cs +++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IncomingEventRecord.cs @@ -44,6 +44,10 @@ public class IncomingEventRecord : ExtraProperties = new ExtraPropertyDictionary(); this.SetDefaultsForExtraProperties(); + foreach (var property in eventInfo.ExtraProperties) + { + this.SetProperty(property.Key, property.Value); + } } public IncomingEventInfo ToIncomingEventInfo() diff --git a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/OutgoingEventRecord.cs b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/OutgoingEventRecord.cs index a7f3d5ab14..24574d3600 100644 --- a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/OutgoingEventRecord.cs +++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/OutgoingEventRecord.cs @@ -37,6 +37,10 @@ public class OutgoingEventRecord : ExtraProperties = new ExtraPropertyDictionary(); this.SetDefaultsForExtraProperties(); + foreach (var property in eventInfo.ExtraProperties) + { + this.SetProperty(property.Key, property.Value); + } } public OutgoingEventInfo ToOutgoingEventInfo()