Package de.hybris.platform.cronjob
Class StaleCronJobUnlockerTest.TestStaleCronJobUnlocker.Builder
java.lang.Object
de.hybris.platform.cronjob.StaleCronJobUnlockerTest.TestStaleCronJobUnlocker.Builder
- Enclosing class:
- StaleCronJobUnlockerTest.TestStaleCronJobUnlocker
-
Method Summary
Modifier and TypeMethodDescriptionbuild()withGetAllNodesSupplier(Supplier<Collection<ClusterNodeInfo>> getAllNodesSupplier) withGetNodesIdsFunction(Function<Collection<ClusterNodeInfo>, List<Integer>> getNodesIdsFunction) withGetStaleNodesIdsFunction(BiFunction<Collection<ClusterNodeInfo>, Predicate<ClusterNodeInfo>, List<Integer>> f) withTenant(Tenant tenant) withUnlockCronJobsForNodeIdsConsumer(BiConsumer<Collection<Integer>, Collection<Integer>> unlockCronJobsForNodeIdsConsumer) withUnlockCronJobsFromLocalInstanceRunnable(Runnable unlockCronJobsFromLocalInstanceRunnable)
-
Method Details
-
withTenant
-
withGetStaleNodesIdsFunction
public StaleCronJobUnlockerTest.TestStaleCronJobUnlocker.Builder withGetStaleNodesIdsFunction(BiFunction<Collection<ClusterNodeInfo>, Predicate<ClusterNodeInfo>, List<Integer>> f) -
withGetNodesIdsFunction
public StaleCronJobUnlockerTest.TestStaleCronJobUnlocker.Builder withGetNodesIdsFunction(Function<Collection<ClusterNodeInfo>, List<Integer>> getNodesIdsFunction) -
withUnlockCronJobsForNodeIdsConsumer
public StaleCronJobUnlockerTest.TestStaleCronJobUnlocker.Builder withUnlockCronJobsForNodeIdsConsumer(BiConsumer<Collection<Integer>, Collection<Integer>> unlockCronJobsForNodeIdsConsumer) -
withGetAllNodesSupplier
public StaleCronJobUnlockerTest.TestStaleCronJobUnlocker.Builder withGetAllNodesSupplier(Supplier<Collection<ClusterNodeInfo>> getAllNodesSupplier) -
withUnlockCronJobsFromLocalInstanceRunnable
public StaleCronJobUnlockerTest.TestStaleCronJobUnlocker.Builder withUnlockCronJobsFromLocalInstanceRunnable(Runnable unlockCronJobsFromLocalInstanceRunnable) -
build
-