private void validateDescriptor()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageDeserializer.java [65:85]

• 19 lines of code
• 12 McCabe index (conditional complexity)

    private void validateDescriptor(RecordClassDescriptor msgType) {
        if (instrumentField != null && msgType.hasField(instrumentField))
            throw new IllegalArgumentException("Field \"" + instrumentField + "\" already exists in TimeBase message");
        if (symbolField != null && msgType.hasField(symbolField))
            throw new IllegalArgumentException("Field \"" + symbolField + "\" already exists in TimeBase message");
        if (timeField != null && msgType.hasField(timeField))
            throw new IllegalArgumentException("Field \"" + timeField + "\" already exists in TimeBase message");

        for (String fieldName : fieldMap.getSourceFields()) {
            if (!msgType.hasField(fieldName)) {
                throw new IllegalArgumentException("TimeBase message does not contain renamed field \"" + fieldName + "\"");
            }
        }

        if (keyFields != null) {
            for (String fieldName : keyFields) {
                if (!msgType.hasField(fieldName))
                    throw new IllegalArgumentException("TimeBase message does not contain key field \"" + fieldName + "\"");
            }
        }
    }