@Override
  public synchronized void writeNextSet(ChangeSet changeSet) {
    if (isCompletelyBroken) return;

    try {
      try (AbstractStorage.StorageDataOutput out = myStorage.writeStream(myStorage.createNextRecord(), true)) {
        changeSet.write(out);
      }
      myStorage.setLastId(myLastId);
    }
    catch (IOException e) {
      handleError(e, null);
    }
  }
@Override
  public synchronized void writeNextSet(ChangeSet changeSet)