public void enqueueForRetry(final ReconciliationTask task) {
LOG.trace("Reconciliation task re-queued for re-execution {}",task);
reconTaskManager.cacheTask(task, taskTriager.schedule(
- () -> task.checkReadinessAndProcess(), task.retryDelayInMills(), TimeUnit.MILLISECONDS
+ task::checkReadinessAndProcess, task.retryDelayInMills(), TimeUnit.MILLISECONDS
)
);
}
final MonitorCallBack callback) {
final ImmutableMap<String, MonitorRequest> reqMap = Maps.uniqueIndex(monitorRequest,
- input -> input.getTableName());
+ MonitorRequest::getTableName);
final MonitorHandle monitorHandle = new MonitorHandle(UUID.randomUUID().toString());
registerCallback(monitorHandle, callback, dbSchema);
final MonitorCallBack callback) {
final ImmutableMap<String, MonitorRequest> reqMap = Maps.uniqueIndex(monitorRequest,
- input -> input.getTableName());
+ MonitorRequest::getTableName);
registerCallback(monitorHandle, callback, dbSchema);
public void enqueueForRetry(final ReconciliationTask task) {
LOG.trace("Reconciliation task re-queued for re-execution {}",task);
reconTaskManager.cacheTask(task, taskTriager.schedule(
- () -> task.checkReadinessAndProcess(), task.retryDelayInMills(), TimeUnit.MILLISECONDS
+ task::checkReadinessAndProcess, task.retryDelayInMills(), TimeUnit.MILLISECONDS
)
);
}