private void validateNewField()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java [461:470]

• 8 lines of code
• 5 McCabe index (conditional complexity)

    private void validateNewField(Schema schema, String newField) {
        if (fieldMap.hasDestinationAlias(newField))
            throw new IllegalArgumentException("Specified new field name \"" + newField + "\" is already used as a field alias");

        if (schema.field(newField) != null && !fieldMap.hasSourceAlias(newField))
            throw new IllegalArgumentException("Schema already contains specified new field: " + newField);

        if (fieldMap.isFieldPath(newField))
            throw new IllegalArgumentException("Specified new filed name \"" + newField + "\" contains path separator character");
    }