'Send the subscription request to the server'

def replicate(self, stream_name, token):

    if (stream_name not in STREAMS_MAP):
        raise Exception(('Invalid    stream    name    %r' % (stream_name,)))
    logger.info('[%s]    Subscribing    to    replication    stream:    %r    from    %r', self.id(), stream_name, token)
    self.send_command(ReplicateCommand(stream_name, token))
