'Used to inform replication listeners that something has happend
without waking up any of the normal user event streams'

def on_new_replication_data(self):

    with PreserveLoggingContext():
        self.notify_replication()
