'Helper method to start a replication connection to the remote server
using TCP.'

def start_replication(self, hs):

    client_name = hs.config.worker_name
    factory = ReplicationClientFactory(hs, client_name, self)
    host = hs.config.worker_replication_host
    port = hs.config.worker_replication_port
    reactor.connectTCP(host, port, factory)
