diff --git a/hazelcast/src/main/java/com/hazelcast/internal/journal/EventJournalReadOperation.java b/hazelcast/src/main/java/com/hazelcast/internal/journal/EventJournalReadOperation.java
index <HASH>..<HASH> 100644
--- a/hazelcast/src/main/java/com/hazelcast/internal/journal/EventJournalReadOperation.java
+++ b/hazelcast/src/main/java/com/hazelcast/internal/journal/EventJournalReadOperation.java
@@ -118,8 +118,7 @@ public abstract class EventJournalReadOperation<T, J> extends Operation
 
         if (minSize == 0) {
             if (!journal.isNextAvailableSequence(namespace, partitionId, sequence)) {
-                sequence = journal.readMany(namespace, partitionId, sequence, resultSet);
-                resultSet.setNextSequenceToReadFrom(sequence);
+                readMany(journal, partitionId);
             }
             return false;
         }
@@ -134,9 +133,13 @@ public abstract class EventJournalReadOperation<T, J> extends Operation
             return true;
         }
 
+        readMany(journal, partitionId);
+        return !resultSet.isMinSizeReached();
+    }
+
+    private void readMany(EventJournal<J> journal, int partitionId) {
         sequence = journal.readMany(namespace, partitionId, sequence, resultSet);
         resultSet.setNextSequenceToReadFrom(sequence);
-        return !resultSet.isMinSizeReached();
     }
 
     @Override
Refactor to readMany() method