From 2270ea0dc6525f881992170ee3c04e063ea10275 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Halil=20=C4=B0brahim=20Kalkan?= Date: Mon, 25 Sep 2023 11:52:46 +0300 Subject: [PATCH] Added extension methods for mongodb to configure eventbox collections --- .../EventInboxMongoModelBuilderExtensions.cs | 16 ++++++++++++++++ .../EventOutboxMongoModelBuilderExtensions.cs | 17 +++++++++++++++++ 2 files changed, 33 insertions(+) create mode 100644 framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/EventInboxMongoModelBuilderExtensions.cs create mode 100644 framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/EventOutboxMongoModelBuilderExtensions.cs diff --git a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/EventInboxMongoModelBuilderExtensions.cs b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/EventInboxMongoModelBuilderExtensions.cs new file mode 100644 index 0000000000..1623bd9ccf --- /dev/null +++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/EventInboxMongoModelBuilderExtensions.cs @@ -0,0 +1,16 @@ +using Volo.Abp.Data; + +namespace Volo.Abp.MongoDB.DistributedEvents; + +public static class EventInboxMongoModelBuilderExtensions +{ + public static void ConfigureEventInbox(this IMongoModelBuilder builder) + { + Check.NotNull(builder, nameof(builder)); + + builder.Entity(b => + { + b.CollectionName = AbpCommonDbProperties.DbTablePrefix + "EventInbox"; + }); + } +} diff --git a/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/EventOutboxMongoModelBuilderExtensions.cs b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/EventOutboxMongoModelBuilderExtensions.cs new file mode 100644 index 0000000000..15001d6737 --- /dev/null +++ b/framework/src/Volo.Abp.MongoDB/Volo/Abp/MongoDB/DistributedEvents/EventOutboxMongoModelBuilderExtensions.cs @@ -0,0 +1,17 @@ +using JetBrains.Annotations; +using Volo.Abp.Data; + +namespace Volo.Abp.MongoDB.DistributedEvents; + +public static class EventOutboxMongoModelBuilderExtensions +{ + public static void ConfigureEventOutbox([NotNull] this IMongoModelBuilder builder) + { + Check.NotNull(builder, nameof(builder)); + + builder.Entity(b => + { + b.CollectionName = AbpCommonDbProperties.DbTablePrefix + "EventOutbox"; + }); + } +}