'We\'ve received an ack for federation stream from a client.'

@measure_func('repl.federation_ack')
def federation_ack(self, token):

    federation_ack_counter.inc()
    if self.federation_sender:
        self.federation_sender.federation_ack(token)
