Disabling receiving is running in SendOnly mode

Fixes #78
Particular · Apr 16, 2015 · 7ce46ad · 7ce46ad
1 parent eb55676
commit 7ce46ad
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/src/NServiceBus.SqlServer/Config/SqlServerTransportFeature.cs b/src/NServiceBus.SqlServer/Config/SqlServerTransportFeature.cs
@@ -56,15 +56,19 @@ protected override void Configure(FeatureConfigurationContext context, string co
                 config.Configure(context, connectionStringWithSchema);
             }
 
-            context.Container.ConfigureComponent<TransportNotifications>(DependencyLifecycle.SingleInstance);
             context.Container.ConfigureComponent<SqlServerMessageSender>(DependencyLifecycle.InstancePerCall);
-            context.Container.ConfigureComponent<SqlServerQueueCreator>(DependencyLifecycle.InstancePerCall);
 
-            var errorQueue = ErrorQueueSettings.GetConfiguredErrorQueue(context.Settings);
-            context.Container.ConfigureComponent(b => new ReceiveStrategyFactory(b.Build<PipelineExecutor>(), b.Build<LocalConnectionParams>(), errorQueue),  DependencyLifecycle.InstancePerCall);
+            if (!context.Settings.GetOrDefault<bool>("Endpoint.SendOnly"))
+            {
+                context.Container.ConfigureComponent<TransportNotifications>(DependencyLifecycle.SingleInstance);
+                context.Container.ConfigureComponent<SqlServerQueueCreator>(DependencyLifecycle.InstancePerCall);
+
+                var errorQueue = ErrorQueueSettings.GetConfiguredErrorQueue(context.Settings);
+                context.Container.ConfigureComponent(b => new ReceiveStrategyFactory(b.Build<PipelineExecutor>(), b.Build<LocalConnectionParams>(), errorQueue), DependencyLifecycle.InstancePerCall);
 
-            context.Container.ConfigureComponent<SqlServerPollingDequeueStrategy>(DependencyLifecycle.InstancePerCall);
-            context.Container.ConfigureComponent(b => new SqlServerStorageContext(b.Build<PipelineExecutor>(), b.Build<LocalConnectionParams>()),  DependencyLifecycle.InstancePerUnitOfWork);
+                context.Container.ConfigureComponent<SqlServerPollingDequeueStrategy>(DependencyLifecycle.InstancePerCall);
+                context.Container.ConfigureComponent(b => new SqlServerStorageContext(b.Build<PipelineExecutor>(), b.Build<LocalConnectionParams>()), DependencyLifecycle.InstancePerUnitOfWork);
+            }
         }
     }