public RawMessageDeserializer()

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

• 16 lines of code
• 1 McCabe index (conditional complexity)

    public RawMessageDeserializer(RecordClassDescriptor msgType, TBConnectorConfig config) {
        this.msgType = msgType;
        this.instrumentField = config.getInstrumentField();
        this.symbolField = config.getSymbolField();
        this.timeField = config.getTimeField();
        this.fieldSelection = config.getFieldSelection();
        this.fieldMap = config.getNameAliases();
        this.keyFields = config.getKeyFields();
        this.tbMessageId = config.getTBMessageIDField();
        this.topic = config.getTopic();

        this.iso8601Format = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
        this.iso8601Format.setTimeZone(TimeZone.getTimeZone("UTC"));
        this.timeOfDayFormat = new SimpleDateFormat("HH:mm:ss.SSS");
        this.timeOfDayFormat.setTimeZone(TimeZone.getTimeZone("UTC"));

        getSchema(msgType); // build schema now
    }