diff --git a/framework/src/Volo.Abp.MongoDB/Volo/Abp/Domain/Repositories/MongoDB/MongoDbRepository.cs b/framework/src/Volo.Abp.MongoDB/Volo/Abp/Domain/Repositories/MongoDB/MongoDbRepository.cs
index a40117e0ff..a90549cf5d 100644
--- a/framework/src/Volo.Abp.MongoDB/Volo/Abp/Domain/Repositories/MongoDB/MongoDbRepository.cs
+++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/Domain/Repositories/MongoDB/MongoDbRepository.cs
@@ -570,12 +570,13 @@ namespace Volo.Abp.Domain.Repositories.MongoDB
           );
         }
 
-        protected virtual async Task ApplyAbpConceptsForAddedEntityAsync(TEntity entity)
+        protected virtual Task ApplyAbpConceptsForAddedEntityAsync(TEntity entity)
         {
             CheckAndSetId(entity);
             SetCreationAuditProperties(entity);
             TriggerEntityCreateEvents(entity);
             TriggerDomainEvents(entity);
+            return Task.CompletedTask;
         }
 
         private void TriggerEntityCreateEvents(TEntity entity)
diff --git a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/AbpMongoDbModule.cs b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/AbpMongoDbModule.cs
index d32f015a33..9a5d327055 100644
--- a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/AbpMongoDbModule.cs
+++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/AbpMongoDbModule.cs
@@ -5,6 +5,7 @@ using Volo.Abp.Domain.Repositories.MongoDB;
 using Volo.Abp.Modularity;
 using Volo.Abp.MongoDB.DependencyInjection;
 using Volo.Abp.Uow.MongoDB;
+using Volo.Abp.MongoDB.DistributedEvents;
 
 namespace Volo.Abp.MongoDB
 {
@@ -32,6 +33,16 @@ namespace Volo.Abp.MongoDB
                 typeof(IMongoDbRepositoryFilterer<,>),
                 typeof(MongoDbRepositoryFilterer<,>)
             );
+
+            context.Services.AddTransient(
+                typeof(IDbContextEventOutbox<>),
+                typeof(DbContextEventOutbox<>)
+            );
+            
+            context.Services.AddTransient(
+                typeof(IDbContextEventInbox<>),
+                typeof(DbContextEventInbox<>)
+            );
         }
     }
 }
diff --git a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/DbContextEventInbox.cs b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/DbContextEventInbox.cs
new file mode 100644
index 0000000000..955f142add
--- /dev/null
+++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/DbContextEventInbox.cs
@@ -0,0 +1,36 @@
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Volo.Abp.EventBus.Distributed;
+
+namespace Volo.Abp.MongoDB.DistributedEvents
+{
+    public class DbContextEventInbox<TDbContext> : IDbContextEventInbox<TDbContext> 
+        where TDbContext : IHasEventInbox
+    {
+        public Task EnqueueAsync(IncomingEventInfo incomingEvent)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<List<IncomingEventInfo>> GetWaitingEventsAsync(int maxCount)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task MarkAsProcessedAsync(Guid id)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<bool> ExistsByMessageIdAsync(string messageId)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task DeleteOldEventsAsync()
+        {
+            throw new NotImplementedException();
+        }
+    }
+}
\ No newline at end of file
diff --git a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/DbContextEventOutbox.cs b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/DbContextEventOutbox.cs
new file mode 100644
index 0000000000..3b054732be
--- /dev/null
+++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/DbContextEventOutbox.cs
@@ -0,0 +1,27 @@
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Volo.Abp.EventBus.Distributed;
+using Volo.Abp.Uow;
+
+namespace Volo.Abp.MongoDB.DistributedEvents
+{
+    public class DbContextEventOutbox<TDbContext> : IDbContextEventOutbox<TDbContext> 
+        where TDbContext : IHasEventOutbox
+    {
+        public Task EnqueueAsync(OutgoingEventInfo outgoingEvent)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<List<OutgoingEventInfo>> GetWaitingEventsAsync(int maxCount)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task DeleteAsync(Guid id)
+        {
+            throw new NotImplementedException();
+        }
+    }
+}
\ No newline at end of file
diff --git a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IDbContextEventInbox.cs b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IDbContextEventInbox.cs
new file mode 100644
index 0000000000..d76bac2412
--- /dev/null
+++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IDbContextEventInbox.cs
@@ -0,0 +1,10 @@
+using Volo.Abp.EventBus.Distributed;
+
+namespace Volo.Abp.MongoDB.DistributedEvents
+{
+    public interface IDbContextEventInbox<TDbContext> : IEventInbox
+        where TDbContext : IHasEventInbox
+    {
+        
+    }
+}
\ No newline at end of file
diff --git a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IDbContextEventOutbox.cs b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IDbContextEventOutbox.cs
new file mode 100644
index 0000000000..bcc0a4705a
--- /dev/null
+++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IDbContextEventOutbox.cs
@@ -0,0 +1,10 @@
+using Volo.Abp.EventBus.Distributed;
+
+namespace Volo.Abp.MongoDB.DistributedEvents
+{
+    public interface IDbContextEventOutbox<TDbContext> : IEventOutbox
+        where TDbContext : IHasEventOutbox
+    {
+        
+    }
+}
\ No newline at end of file
diff --git a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IHasEventInbox.cs b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IHasEventInbox.cs
new file mode 100644
index 0000000000..387e860bce
--- /dev/null
+++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IHasEventInbox.cs
@@ -0,0 +1,9 @@
+using MongoDB.Driver;
+
+namespace Volo.Abp.MongoDB.DistributedEvents
+{
+    public interface IHasEventInbox : IAbpMongoDbContext
+    {
+        IMongoCollection<IncomingEventRecord> IncomingEvents { get; set; }
+    }
+}
\ No newline at end of file
diff --git a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IHasEventOutbox.cs b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IHasEventOutbox.cs
new file mode 100644
index 0000000000..cf57aaa699
--- /dev/null
+++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IHasEventOutbox.cs
@@ -0,0 +1,9 @@
+using MongoDB.Driver;
+
+namespace Volo.Abp.MongoDB.DistributedEvents
+{
+    public interface IHasEventOutbox : IAbpMongoDbContext
+    {
+        IMongoCollection<OutgoingEventRecord> OutgoingEvents { get; set; }
+    }
+}
\ No newline at end of file
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
new file mode 100644
index 0000000000..5e9d07c33f
--- /dev/null
+++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/IncomingEventRecord.cs
@@ -0,0 +1,66 @@
+using System;
+using Volo.Abp.Auditing;
+using Volo.Abp.Data;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.EventBus.Distributed;
+
+namespace Volo.Abp.MongoDB.DistributedEvents
+{
+    public class IncomingEventRecord : 
+        BasicAggregateRoot<Guid>,
+        IHasExtraProperties,
+        IHasCreationTime
+    {
+        public static int MaxEventNameLength { get; set; } = 256;
+        
+        public ExtraPropertyDictionary ExtraProperties { get; private set; }
+
+        public string MessageId { get; private set; }
+
+        public string EventName { get; private set; }
+        
+        public byte[] EventData { get; private set; }
+        
+        public DateTime CreationTime { get; private set; }
+        
+        public bool Processed { get; set; }
+        
+        public DateTime? ProcessedTime { get; set; }
+
+        protected IncomingEventRecord()
+        {
+            ExtraProperties = new ExtraPropertyDictionary();
+            this.SetDefaultsForExtraProperties();
+        }
+
+        public IncomingEventRecord(
+            IncomingEventInfo eventInfo)
+            : base(eventInfo.Id)
+        {
+            MessageId = eventInfo.MessageId;
+            EventName = eventInfo.EventName;
+            EventData = eventInfo.EventData;
+            CreationTime = eventInfo.CreationTime;
+
+            ExtraProperties = new ExtraPropertyDictionary();
+            this.SetDefaultsForExtraProperties();
+        }
+
+        public IncomingEventInfo ToIncomingEventInfo()
+        {
+            return new IncomingEventInfo(
+                Id,
+                MessageId,
+                EventName,
+                EventData,
+                CreationTime
+            );
+        }
+
+        public void MarkAsProcessed(DateTime processedTime)
+        {
+            Processed = true;
+            ProcessedTime = processedTime;
+        }
+    }
+}
\ No newline at end of file
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
new file mode 100644
index 0000000000..c38de0cd91
--- /dev/null
+++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/OutgoingEventRecord.cs
@@ -0,0 +1,52 @@
+using System;
+using Volo.Abp.Auditing;
+using Volo.Abp.Data;
+using Volo.Abp.Domain.Entities;
+using Volo.Abp.EventBus.Distributed;
+
+namespace Volo.Abp.MongoDB.DistributedEvents
+{
+    public class OutgoingEventRecord : 
+        BasicAggregateRoot<Guid>,
+        IHasExtraProperties,
+        IHasCreationTime
+    {
+        public static int MaxEventNameLength { get; set; } = 256;
+        
+        public ExtraPropertyDictionary ExtraProperties { get; private set; }
+
+        public string EventName { get; private set; }
+        
+        public byte[] EventData { get; private set; }
+        
+        public DateTime CreationTime { get; private set; }
+
+        protected OutgoingEventRecord()
+        {
+            ExtraProperties = new ExtraPropertyDictionary();
+            this.SetDefaultsForExtraProperties();
+        }
+
+        public OutgoingEventRecord(
+            OutgoingEventInfo eventInfo)
+            : base(eventInfo.Id)
+        {
+            EventName = eventInfo.EventName;
+            EventData = eventInfo.EventData;
+            CreationTime = eventInfo.CreationTime;
+
+            ExtraProperties = new ExtraPropertyDictionary();
+            this.SetDefaultsForExtraProperties();
+        }
+
+        public OutgoingEventInfo ToOutgoingEventInfo()
+        {
+            return new OutgoingEventInfo(
+                Id,
+                EventName,
+                EventData,
+                CreationTime
+            );
+        }
+    }
+}
\ No newline at end of file