private long getLastMessageTimestamp()

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

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

    private long getLastMessageTimestamp() {
        RawMessageDeserializer deserializer = getDeserializer();
        try (TickCursor cursor = msgStream.select(Long.MAX_VALUE, new SelectionOptions(true, false, true))) {
            if (cursor.next()) {
                return cursor.getMessage().getTimeStampMs();
            }
        }
        return 0;
    }