diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/AcknowledgementMirroringMessageStream.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/AcknowledgementMirroringMessageStream.java
index 3cc75781f..4edc35652 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/AcknowledgementMirroringMessageStream.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/AcknowledgementMirroringMessageStream.java
@@ -14,6 +14,7 @@ import java.util.function.BiConsumer;
 import com.google.common.annotations.VisibleForTesting;
 import io.micrometer.core.instrument.Counter;
 import io.micrometer.core.instrument.Metrics;
+import org.reactivestreams.Subscription;
 import org.whispersystems.textsecuregcm.metrics.MetricsUtil;
 import org.whispersystems.textsecuregcm.storage.foundationdb.FoundationDbMessageStream;
 import org.whispersystems.textsecuregcm.util.UUIDUtil;
@@ -80,6 +81,12 @@ public class AcknowledgementMirroringMessageStream implements MessageStream {
       }
     }
 
+    @Override
+    protected void hookOnSubscribe(final Subscription subscription) {
+      // The base `hookOnSubscribe` requests `Long.MAX_VALUE` elements, and that is something we're explicitly trying
+      // to avoid with this subscriber
+    }
+
     @Override
     protected void hookOnNext(final MessageStreamEntry.Envelope envelope) {
       mirroredMessageHandler.accept(