diff --git a/synapse/replication/tcp/resource.py b/synapse/replication/tcp/resource.py
index 44fb3551c1..4764f3b121 100644
--- a/synapse/replication/tcp/resource.py
+++ b/synapse/replication/tcp/resource.py
@@ -42,7 +42,7 @@ class ReplicationStreamProtocolFactory(Factory):
     """
 
     def __init__(self, hs):
-        self.handler = hs.get_tcp_replication()
+        self.command_handler = hs.get_tcp_replication()
         self.clock = hs.get_clock()
         self.server_name = hs.config.server_name
 
@@ -52,7 +52,7 @@ class ReplicationStreamProtocolFactory(Factory):
 
     def buildProtocol(self, addr):
         return ServerReplicationStreamProtocol(
-            self.server_name, self.clock, self.handler
+            self.server_name, self.clock, self.command_handler
         )