Making use of GetChunkQuery

Particular · Jul 17, 2014 · 6349782 · 6349782
1 parent 809fcbb
commit 6349782
Showing 1 changed file with 6 additions and 11 deletions.
diff --git a/src/timeout/NServiceBus.Timeout.Hosting.Windows/Persistence/RavenTimeoutPersistence.cs b/src/timeout/NServiceBus.Timeout.Hosting.Windows/Persistence/RavenTimeoutPersistence.cs
@@ -106,17 +106,12 @@ public List<Tuple<string, DateTime>> GetNextChunk(DateTime startSlice, out DateT
                     {
                         session.Advanced.AllowNonAuthoritativeInformation = true;
 
-                        var query = session.Query<TimeoutData>("RavenTimeoutPersistence/TimeoutDataSortedByTime")
-                            .Where(
-                                t =>
-                                    t.OwningTimeoutManager == String.Empty ||
-                                    t.OwningTimeoutManager == Configure.EndpointName)
-                            .Where(
-                                t =>
-                                    t.Time > startSlice &&
-                                    t.Time <= now)
-                            .OrderBy(t => t.Time)
-                            .Select(t => new { t.Id, t.Time })
+                        var query = GetChunkQuery(session)
+                            .Where(
+                                t =>
+                                    t.Time > startSlice &&
+                                    t.Time <= now)
+                            .Select(t => new { t.Id, t.Time })
                             .Statistics(out stats);
                         do
                         {