public void loadScheduleMessageOffsets()

in src/main/java/org/apache/rocketmq/exporter/model/BrokerRuntimeStats.java [181:192]

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

    public void loadScheduleMessageOffsets(KVTable kvTable) {
        for (String key : kvTable.getTable().keySet()) {
            if (key.startsWith("scheduleMessageOffset")) {
                String[] arr = kvTable.getTable().get(key).split(",");
                ScheduleMessageOffsetTable table = new ScheduleMessageOffsetTable(
                        Long.parseLong(arr[0]),
                        Long.parseLong(arr[1])
                );
                this.scheduleMessageOffsetTables.add(table);
            }
        }
    }