'As per TransactionQueue'

def send_edu(self, destination, edu_type, content, key=None):

    pos = self._next_pos()
    edu = Edu(origin=self.server_name, destination=destination, edu_type=edu_type, content=content)
    if key:
        assert isinstance(key, tuple)
        self.keyed_edu[(destination, key)] = edu
        self.keyed_edu_changed[pos] = (destination, key)
    else:
        self.edus[pos] = edu
    self.notifier.on_new_replication_data()
