diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/workers/ScourMessageCacheCommand.java b/service/src/main/java/org/whispersystems/textsecuregcm/workers/ScourMessageCacheCommand.java
index 546a69e1a..1505ad563 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/workers/ScourMessageCacheCommand.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/workers/ScourMessageCacheCommand.java
@@ -80,7 +80,9 @@ public class ScourMessageCacheCommand extends ConfiguredCommand<WhisperServerCon
         List<ScoredValue<byte[]>> messages;
 
         do {
-            messages = redisClient.withBinaryClient(connection -> connection.sync().zpopmin(queueKeyBytes, MESSAGE_PAGE_SIZE));
+            final int start = messageCount;
+
+            messages = redisClient.withBinaryClient(connection -> connection.sync().zrangeWithScores(queueKeyBytes, start, start + MESSAGE_PAGE_SIZE));
 
             for (final ScoredValue<byte[]> scoredValue : messages) {
                 persistMessage(accountNumber, deviceId, scoredValue.getValue());