Merge pull request #296 from Particular/hotfix-4.1.1

fix outbox diagnostics
Particular · May 28, 2018 · 64980e2 · 64980e2
2 parents 64209d9 + 4200177
commit 64980e2
Showing 1 changed file with 10 additions and 12 deletions.
diff --git a/src/SqlPersistence/Outbox/SqlOutboxFeature.cs b/src/SqlPersistence/Outbox/SqlOutboxFeature.cs
@@ -28,20 +28,18 @@ protected override void Setup(FeatureConfigurationContext context)
             return;
         }
 
-        context.RegisterStartupTask(b =>
-        {
-            var frequencyToRunCleanup = settings.GetOrDefault<TimeSpan?>(FrequencyToRunDeduplicationDataCleanup) ?? TimeSpan.FromMinutes(1);
-            var timeToKeepDeduplicationData = settings.GetOrDefault<TimeSpan?>(TimeToKeepDeduplicationData) ?? TimeSpan.FromDays(7);
+        var frequencyToRunCleanup = settings.GetOrDefault<TimeSpan?>(FrequencyToRunDeduplicationDataCleanup) ?? TimeSpan.FromMinutes(1);
+        var timeToKeepDeduplicationData = settings.GetOrDefault<TimeSpan?>(TimeToKeepDeduplicationData) ?? TimeSpan.FromDays(7);
 
-            settings.AddStartupDiagnosticsSection("NServiceBus.Persistence.Sql.Outbox", new
-            {
-                CleanupDisabled = false,
-                TimeToKeepDeduplicationData = timeToKeepDeduplicationData,
-                FrequencyToRunDeduplicationDataCleanup = frequencyToRunCleanup
-            });
-
-            return new OutboxCleaner(outboxPersister.RemoveEntriesOlderThan, b.Build<CriticalError>().Raise, timeToKeepDeduplicationData, frequencyToRunCleanup, new AsyncTimer());
+        settings.AddStartupDiagnosticsSection("NServiceBus.Persistence.Sql.Outbox", new
+        {
+            CleanupDisabled = false,
+            TimeToKeepDeduplicationData = timeToKeepDeduplicationData,
+            FrequencyToRunDeduplicationDataCleanup = frequencyToRunCleanup
         });
+
+        context.RegisterStartupTask(b => 
+            new OutboxCleaner(outboxPersister.RemoveEntriesOlderThan, b.Build<CriticalError>().Raise, timeToKeepDeduplicationData, frequencyToRunCleanup, new AsyncTimer()));
     }
 
     internal const string TimeToKeepDeduplicationData = "Persistence.Sql.Outbox.TimeToKeepDeduplicationData";