'Called when we get new replication data. By default this just pokes
the slave store.
Can be overriden in subclasses to handle more.'

def on_rdata(self, stream_name, token, rows):

    logger.info('Received    rdata    %s    ->    %s', stream_name, token)
    self.store.process_replication_rows(stream_name, token, rows)
