Merge branch 'hotfix-4.3.7'

Particular · Oct 2, 2014 · 7a1b34a · 7a1b34a
2 parents 3b69bff + d680565
commit 7a1b34a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/NServiceBus.Core/Persistence/Raven/TimeoutPersister/RavenTimeoutPersistence.cs b/src/NServiceBus.Core/Persistence/Raven/TimeoutPersister/RavenTimeoutPersistence.cs
@@ -32,6 +32,7 @@ private static IRavenQueryable<TimeoutData> GetChunkQuery(IDocumentSession sessi
                 .OrderBy(t => t.Time)
                 .Where(
                     t =>
+						t.OwningTimeoutManager == null ||
                         t.OwningTimeoutManager == String.Empty ||
                         t.OwningTimeoutManager == Configure.EndpointName);
         }
@@ -67,7 +68,7 @@ public List<Tuple<string, DateTime>> GetNextChunk(DateTime startSlice, out DateT
                 // Allow for occasionally cleaning up old timeouts for edge cases where timeouts have been
                 // added after startSlice have been set to a later timout and we might have missed them
                 // because of stale indexes.
-                if (lastCleanupTime.Add(TriggerCleanupEvery) > now || lastCleanupTime == DateTime.MinValue)
+                if (lastCleanupTime.Add(TriggerCleanupEvery) < now || lastCleanupTime == DateTime.MinValue)
                 {                    
                     results.AddRange(GetCleanupChunk(startSlice));
                 }