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

def on_position(self, stream_name, token):

    self.store.process_replication_rows(stream_name, token, [])
