private Struct getLastRecord2()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java [101:110]

• 10 lines of code
• 2 McCabe index (conditional complexity)

    private Struct getLastRecord2() {
        Struct record = null;
        RawMessageDeserializer deserializer = getDeserializer();
        try (TickCursor cursor = msgStream.select(Long.MAX_VALUE, new SelectionOptions(true, false, true))) {
            if (cursor.next()) {
                record = deserializer.deserialize((RawMessage) cursor.getMessage());
            }
        }
        return record;
    }