events.add(item.toEvent());
}
return events;
}
private boolean isRecent(UUID changeId) {
<BUG>return TimeUnit.NANOSECONDS.toMillis(_ticker.read()) - TimeUUIDs.getTimeMillis(changeId) < STALE_UNKNOWN_AGE.getMillis();
</BUG>
}
@Override
public void renew(String subscription, Collection<String> eventKeys, Duration claimTtl) {

events.add(item.toEvent());
}
return events;
}
private boolean isRecent(UUID changeId) {
return _clock.millis() - TimeUUIDs.getTimeMillis(changeId) < STALE_UNKNOWN_AGE.getMillis();
}
@Override
public void renew(String subscription, Collection<String> eventKeys, Duration claimTtl) {
