diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/foundationdb/FoundationDbMessagePublisher.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/foundationdb/FoundationDbMessagePublisher.java
index e361a6882..b4742c08d 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/foundationdb/FoundationDbMessagePublisher.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/foundationdb/FoundationDbMessagePublisher.java
@@ -236,7 +236,7 @@ class FoundationDbMessagePublisher {
             emitMessages();
           }
           case INTERNAL_TRIGGER -> {
-            if (emitter.requestedFromDownstream() > 0) {
+            if (getOutstandingDemand() > 0) {
               setState(State.FETCHING_MESSAGES, event);
               emitMessages();
             }