public Map getValues()

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

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

    public Map<String, Object> getValues(RawMessage msg) {
        final HashMap<String, Object> values = new HashMap<>();
        if (instrumentField != null && msg.getInstrumentType() != null)
            values.put(instrumentField, msg.getInstrumentType().name());
        if (symbolField != null && msg.getSymbol() != null)
            values.put(symbolField, msg.getSymbol().toString());
        if (timeField != null)
            values.put(timeField, msg.getTimeStampMs());

        if (msg.data != null) {
            final UnboundDecoder decoder = getDecoder(msg.type);
            input.setBytes(msg.data, msg.offset, msg.length);

            decoder.beginRead(input);
            while (decoder.nextField()) {
                final NonStaticFieldInfo field = decoder.getField();
                Object value = rawDecoder.readField(field.getType(), decoder);
                values.put(field.getName(), value);
            }
        }
        return values;
    }