disable outbox table creation

a

Author: Christian

src/NServiceBus.NHibernate.TransactionalSession/NHibernateTransactionalSessionExtensions.cs

@@ -48,6 +48,9 @@ public static PersistenceExtensions<NHibernatePersistence> EnableTransactionalSe
             //By default, the endpoint name used is automatically managed and set to the originating endpoint's name unless overridden by setting a value to NHibernateOutbox.ProcessorEndpointKey
             settings.Set(NHibernateOutbox.ProcessorEndpointKey, transactionalSessionOptions.ProcessorAddress);
 
+            // If a remote processor is configured, this endpoint should not create the outbox tables.
+            settings.Set(NHibernateOutbox.DisableOutboxTableCreationSettingKey, true);
+
             return persistenceExtensions;
         }
 

src/NServiceBus.NHibernate/Outbox/NHibernateOutbox.cs

@@ -25,6 +25,7 @@ class NHibernateOutbox : Feature
         internal const string OutboxTransactionIsolationLevelSettingsKey = "NServiceBus.NHibernate.OutboxTransactionIsolationLevel";
         internal const string OutboxTransactionScopeModeIsolationLevelSettingsKey = "NServiceBus.NHibernate.OutboxTransactionScopeModeIsolationLevel";
         internal const string ProcessorEndpointKey = "NHibernate.TransactionalSession.ProcessorEndpoint";
+        internal const string DisableOutboxTableCreationSettingKey = "NServiceBus.NHibernate.DisableOutboxTableCreation";
         /// <summary>
         /// Creates a new instance of the feature
         /// </summary>
@@ -67,7 +68,9 @@ protected override void Setup(FeatureConfigurationContext context)
                 throw new Exception("Custom outbox table name and custom outbox record type cannot be specified at the same time.");
             }
 
-            ApplyMappings(config.Configuration, actualOutboxRecordType, outboxTableName, outboxSchemaName);
+            var disableOutboxTableCreation = context.Settings.GetOrDefault<bool>(DisableOutboxTableCreationSettingKey);
+
+            ApplyMappings(config.Configuration, actualOutboxRecordType, outboxTableName, outboxSchemaName, disableOutboxTableCreation);
 
             var persisterFactory = context.Settings.Get<IOutboxPersisterFactory>();
             context.Services.AddSingleton<IOutboxStorage>(sp =>
@@ -87,11 +90,12 @@ protected override void Setup(FeatureConfigurationContext context)
                 OutboxCleanupCriticalErrorTriggerTime = outboxCleanupCriticalErrorTriggerTime,
                 RecordType = actualOutboxRecordType.FullName,
                 CustomOutboxTableName = outboxTableName,
-                CustomOutboxSchemaName = outboxSchemaName
+                CustomOutboxSchemaName = outboxSchemaName,
+                OutboxTableCreationDisabled = disableOutboxTableCreation
             });
         }
 
-        static void ApplyMappings(Configuration config, Type outboxRecordType, string customOutboxTableName, string customOutboxSchemaName)
+        static void ApplyMappings(Configuration config, Type outboxRecordType, string customOutboxTableName, string customOutboxSchemaName, bool disableSchemaExport = false)
         {
             var mapper = new ModelMapper();
             mapper.BeforeMapClass += (inspector, type, customizer) =>
@@ -104,6 +108,12 @@ static void ApplyMappings(Configuration config, Type outboxRecordType, string cu
                 {
                     customizer.Schema(customOutboxSchemaName);
                 }
+
+                // Set schema-export attribute to none if schema export is disabled
+                if (disableSchemaExport)
+                {
+                    customizer.SchemaAction(SchemaAction.None);
+                }
             };
             mapper.AddMapping(outboxRecordType);
             config.AddMapping(mapper.CompileMappingForAllExplicitlyAddedEntities());