Enabling installers so that error and audit gets created

andreasohlund · Mar 26, 2015 · 4a96c1b · SeanFeldman · Mar 28, 2015 · andreasohlund
1 parent ad02b29
commit 4a96c1b
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 10 deletions.
diff --git a/APIComparer.Backend/Functions.cs b/APIComparer.Backend/Functions.cs
@@ -23,14 +23,15 @@ public static void Host(TextWriter log, CancellationToken cancellationToken)
             configuration.UseTransport<AzureStorageQueueTransport>()
                 .ConnectionString(AzureEnvironment.GetConnectionString);
             configuration.UsePersistence<AzureStoragePersistence>();
-
-            var startableBus = Bus.Create(configuration);
-            startableBus.Start();
-            log.WriteLine("APIComparer.Backend - bus started");
+            configuration.EnableInstallers();
 
-            cancellationToken.WaitHandle.WaitOne();
+            using (Bus.Create(configuration).Start())
+            {
+                log.WriteLine("APIComparer.Backend - bus started");
+
+                cancellationToken.WaitHandle.WaitOne();
+            }
 
-            startableBus.Dispose();
             log.WriteLine("APIComparer.Backend cancelled at " + DateTimeOffset.UtcNow);
         }
     }

diff --git a/APIComparer.Website/BusConfig.cs b/APIComparer.Website/BusConfig.cs
@@ -10,6 +10,8 @@ public static class BusConfig
     {
         public static IBus Setup(ILifetimeScope container)
         {
+            LogManager.Use<DefaultFactory>().Directory(@".\");
+
             var configuration = new BusConfiguration();
             configuration.EndpointName("APIComparer.Website");
             configuration.UseContainer<AutofacBuilder>(x => x.ExistingLifetimeScope(container));
@@ -21,11 +23,9 @@ public static IBus Setup(ILifetimeScope container)
             configuration.DisableFeature<SecondLevelRetries>();
             configuration.DisableFeature<Sagas>();
             configuration.DisableFeature<TimeoutManager>();
+            configuration.EnableInstallers();
 
-            LogManager.Use<DefaultFactory>().Directory(@".\");
-
-            var startableBus = Bus.Create(configuration);
-            return startableBus.Start();
+            return Bus.Create(configuration).Start();
         }
     }
 }