private void processPeriod(final TimePeriod period,
                               final List<DataRetentionRuleAction> sortedRuleActions,
                               final String ruleAge,
                               final Instant now) {
        info(() -> {
            return LogUtil.message(
                    "Considering streams created " +
                            "between {}, {} rule actions:\n{}",
                    getPeriodInfo(period, now),
                    sortedRuleActions.size(),
                    sortedRuleActions.stream()
                            .map(this::getRuleActionInfo)
                            .collect(Collectors.joining("\n")));
        });

        LOGGER.logDurationIfInfoEnabled(
                () ->
                        metaService.delete(sortedRuleActions, period),
                count ->
                        LogUtil.message("Marked {} items as deleted for ruleAge: {}, period: {}",
                                count, ruleAge, period));
    }
Pkg private so we can test with a known now time
stroom-data/stroom-data-retention-impl/src/main/java/stroom/data/retention/impl/DataRetentionPolicyExecutor.java