now() czy dopuszczalne?

@Bean
public Predicate<Issue> myFilter(@Qualifier("age") Integer age) {
    return x -> x.getCreationDate().toLocalDateTime().plusMinutes(age).isBefore(new LocalDateTime());
}

    @Bean
    public IssueFilter issueFilter(@Qualifier("wantedStatus") IssueStatus wantedStatus,
                                   @Qualifier("issueAgeMinutes") Integer issueAgeMinutes,
                                   LocalDateTime nowDateTime) {
        return new IssueFilter(wantedStatus.name, issueAgeMinutes, nowDateTime);
    }

    @Bean
    public LocalDateTime nowDateTime() {
        return new LocalDateTime();
    }

public class IssueFilter implements Predicate<Issue> {

    private String wantedStatusName;
    private Integer issueAgeMinutes;
    private LocalDateTime nowDateTime;

    public IssueFilter(String wantedStatusName, Integer issueAgeMinutes, LocalDateTime nowDateTime) {
        this.wantedStatusName = wantedStatusName;
        this.issueAgeMinutes = issueAgeMinutes;
        this.nowDateTime = nowDateTime;
    }

    @Override
    public boolean test(Issue issue) {
        boolean statusFlag = issue.getStatus().getName().equals(wantedStatusName);
        boolean ageFlag = issue.getCreationDate().toLocalDateTime().plusMinutes(issueAgeMinutes).isBefore(nowDateTime);
        return statusFlag & ageFlag;
    }

    public String getWantedStatusName() {
        return wantedStatusName;
    }

    public void setWantedStatusName(String wantedStatusName) {
        this.wantedStatusName = wantedStatusName;
    }

    public Integer getIssueAgeMinutes() {
        return issueAgeMinutes;
    }

    public void setIssueAgeMinutes(Integer issueAgeMinutes) {
        this.issueAgeMinutes = issueAgeMinutes;
    }

    public LocalDateTime getNowDateTime() {
        return nowDateTime;
    }

    public void setNowDateTime(LocalDateTime nowDateTime) {
        this.nowDateTime = nowDateTime;
    }
}

@Override
    public Iterable<Issue> produce(LocalDateTime dateTime) {
        Iterable<Issue> issues = service.findAllIssues(projectName);

        issueFilter.setNowDateTime(dateTime);

        return StreamSupport.stream(issues.spliterator(), false)
                .sorted((i1, i2) -> localDateTimeComparator.compare(i1.getCreationDate().toLocalDateTime(), i2.getCreationDate().toLocalDateTime()))
                .filter(issueFilter)
                .peek(i -> logger.info("Collected Issue " + i.getKey()))
                .collect(Collectors.toList());
    }

    @Bean
    public IssueFilter issueFilter(@Qualifier("wantedStatus") IssueStatus wantedStatus,
                                   @Qualifier("issueAgeMinutes") Integer issueAgeMinutes,
                                   @Qualifier("systemClockProvider") ClockProvider clockProvider) {
        return new IssueFilterByStatusAndCreationDate(wantedStatus.name, issueAgeMinutes, clockProvider);
    }

    @Bean("systemClockProvider")
    public ClockProvider clockProvider() {
        return () -> Clock.systemDefaultZone();
    }

public final class IssueFilterByStatusAndCreationDate implements IssueFilter {

    private final String wantedStatusName;
    private final Integer issueAgeMinutes;
    private final ClockProvider clockProvider;

    public IssueFilterByStatusAndCreationDate(String wantedStatusName, Integer issueAgeMinutes, ClockProvider clockProvider) {
        this.wantedStatusName = wantedStatusName;
        this.issueAgeMinutes = issueAgeMinutes;
        this.clockProvider = clockProvider;
    }

    @Override
    public boolean test(Issue issue) {
        boolean statusFlag = issue.getStatus().getName().equals(wantedStatusName);
        boolean ageFlag = issue.getCreationDate().toLocalDateTime().plusMinutes(issueAgeMinutes).isBefore(new LocalDateTime(clockProvider.getClock()));
        return statusFlag & ageFlag;
    }
}

interface TimeProvider {
OffsetDateTime nowAsDateTime();
}

@Component
@Profile("!test")
class DefaultTimeProvider implement TimeProvider{
DateTime nowAsDateTime(){
    return DateTime.now();
}
}


@Component
@Profile("test")
class TestTimeProvider implement TimeProvider
private Clock currentClock = Clock.systemDefaultZone();

void setDefaultClock(){
currentClock= Clock.systemDefaultZone();
}

void setFixedClock(DateTime date){
currentClock = Clock.fixed(date); 
}

DateTime nowAsDateTime(){
return DateTime.now(currentClock);
}

public interface IssueFilter extends Predicate<Issue> {

    @Override
    boolean test(Issue issue);
}

public final class IssueFilterByStatusAndCreationDate implements IssueFilter {

    private final String wantedStatusName;
    private final Integer issueAgeMinutes;
    private final JodaDateTimeProvider dateTimeProvider;

    public IssueFilterByStatusAndCreationDate(String wantedStatusName, Integer issueAgeMinutes, JodaDateTimeProvider dateTimeProvider) {
        this.wantedStatusName = wantedStatusName;
        this.issueAgeMinutes = issueAgeMinutes;
        this.dateTimeProvider = dateTimeProvider;
    }

    @Override
    public boolean test(Issue issue) {
        return getStatusFlag(issue) && getAgeFlag(issue);
    }

    private boolean getStatusFlag(Issue issue) {
        return issue.getStatus().getName().equals(wantedStatusName);
    }

    private boolean getAgeFlag(Issue issue) {
        LocalDateTime issueTriggerLocalDateTime = issue.getCreationDate().toLocalDateTime().plusMinutes(issueAgeMinutes);
        LocalDateTime providedLocalDateTime = dateTimeProvider.getDateTime().toLocalDateTime();
        return ! issueTriggerLocalDateTime.isAfter(providedLocalDateTime);
    }
}

public interface JodaDateTimeProvider {
    Long getMillis();
    DateTimeZone getDateTimeZone();

    default DateTime getDateTime() {
        return new DateTime(getMillis(), getDateTimeZone());
    }
}

public class JodaDateTimeProviderCurrent implements JodaDateTimeProvider {
    @Override
    public Long getMillis() {
        return DateTimeUtils.currentTimeMillis();
    }

    @Override
    public DateTimeZone getDateTimeZone() {
        return DateTimeZone.getDefault();
    }
}