Fix now-incorrect Verb reference in MutationTrackingService

iamaleksey · iamaleksey · commit e1ae7d654a0f · 2026-05-20T12:11:48.000+01:00
diff --git a/src/java/org/apache/cassandra/replication/MutationTrackingService.java b/src/java/org/apache/cassandra/replication/MutationTrackingService.java
@@ -1498,7 +1498,7 @@ private void run(Shard shard)
                     // TODO (expected): backoff, rate limits, per host and total
                     PullMutationsRequest request = new PullMutationsRequest(offsets);
                     logger.trace("Requesting pull mutation request from replica {} for missing offset {}", pullFrom, offsets);
-                    MessagingService.instance().send(Message.out(Verb.PULL_MUTATIONS_REQ, request), pullFrom);
+                    MessagingService.instance().send(Message.out(Verb.MT_PULL_MUTATIONS_REQ, request), pullFrom);
                 }
             }
             catch (Throwable throwable)

Original file line number	Diff line number	Diff line change
`@@ -1498,7 +1498,7 @@ private void run(Shard shard)`
`1498`	`1498`	`// TODO (expected): backoff, rate limits, per host and total`
`1499`	`1499`	`PullMutationsRequest request = new PullMutationsRequest(offsets);`
`1500`	`1500`	`logger.trace("Requesting pull mutation request from replica {} for missing offset {}", pullFrom, offsets);`
`1501`		`- MessagingService.instance().send(Message.out(Verb.PULL_MUTATIONS_REQ, request), pullFrom);`
	`1501`	`+ MessagingService.instance().send(Message.out(Verb.MT_PULL_MUTATIONS_REQ, request), pullFrom);`
`1502`	`1502`	`}`
`1503`	`1503`	`}`
`1504`	`1504`	`catch (Throwable throwable)`