diff --git a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardChangesAction.java b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardChangesAction.java
index b059a86e4db19..6bc1f41b5ce49 100644
--- a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardChangesAction.java
+++ b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardChangesAction.java
@@ -306,7 +306,6 @@ protected void asyncShardOperation(
             final IndexShard indexShard = indexService.getShard(request.getShard().id());
             final SeqNoStats seqNoStats = indexShard.seqNoStats();
 
-
             if (request.getFromSeqNo() > seqNoStats.getGlobalCheckpoint()) {
                 assert request.getFromSeqNo() == 1 + seqNoStats.getGlobalCheckpoint();
                 indexShard.addGlobalCheckpointListener(
@@ -332,7 +331,7 @@ protected void asyncShardOperation(
                         },
                         request.getPollTimeout());
             } else {
-                listener.onResponse(shardOperation(request, shardId));
+                super.asyncShardOperation(request, shardId, listener);
             }
         }