protected long getLastReplicatedTimestamp()

in timescaledb-connector/src/main/java/com/epam/deltix/timebase/connector/service/timebase/TimebaseStreamReplicationService.java [110:128]

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

    protected long getLastReplicatedTimestamp(TimescaleSchema schema) {
        String lastTimestampStatement = timescaleSqlGenerator.generateLastTimestampStatement(schema.getName());

        LOG.info().append("Generated last timestamp statement: ").append(lastTimestampStatement).commit();

        long lastTimestamp = timescaleDataService.getLastTimestamp(lastTimestampStatement);

        LOG.info().append("Last timestamp found: ").append(Instant.ofEpochMilli(lastTimestamp)).commit();

        if (lastTimestamp > 0) {
            String deleteLastTimestampStatement = timescaleSqlGenerator.generateDeleteLastTimestampStatement(schema.getName());

            LOG.info().append("Generated delete last timestamp statement: ").append(deleteLastTimestampStatement).commit();

            timescaleDataService.deleteLastTimestampData(deleteLastTimestampStatement, lastTimestamp);
        }

        return lastTimestamp;
    }