Package de.hybris.platform.cronjob.jalo
Class CronJobManager.DefaultStrandedCronJobsResolutionHandler
java.lang.Object
de.hybris.platform.util.StrandedItemsRegistry.StrandedItemsResolutionHandler<org.apache.commons.lang3.tuple.Pair<PK,Integer>>
de.hybris.platform.cronjob.jalo.CronJobManager.DefaultStrandedCronJobsResolutionHandler
- Enclosing class:
- CronJobManager
protected class CronJobManager.DefaultStrandedCronJobsResolutionHandler
extends StrandedItemsRegistry.StrandedItemsResolutionHandler<org.apache.commons.lang3.tuple.Pair<PK,Integer>>
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionfilterItemsToResolve(Set<PK> itemsToResolve, StrandedItemsRegistry.StrandedItemContextProvider contextProvider) The method to filter the items that are marked as stranded and should be resolved.Method to obtain the PK of item returned byStrandedItemsRegistry.StrandedItemsResolutionHandler.filterItemsToResolve(Set, StrandedItemContextProvider)resolveStrandedItems(List<org.apache.commons.lang3.tuple.Pair<PK, Integer>> itemsToResolve, StrandedItemsRegistry.StrandedItemContextProvider contextProvider) The method to resolve the stranded items.
-
Constructor Details
-
DefaultStrandedCronJobsResolutionHandler
protected DefaultStrandedCronJobsResolutionHandler()
-
-
Method Details
-
filterItemsToResolve
public List<org.apache.commons.lang3.tuple.Pair<PK,Integer>> filterItemsToResolve(Set<PK> itemsToResolve, StrandedItemsRegistry.StrandedItemContextProvider contextProvider) Description copied from class:StrandedItemsRegistry.StrandedItemsResolutionHandlerThe method to filter the items that are marked as stranded and should be resolved. The items that are marked as stranded and should not be resolved (ex. other mechanism has resolved the problem or the marking was too excessive) should be filtered out (should not be returned in a result of this method's invocation).- Specified by:
filterItemsToResolvein classStrandedItemsRegistry.StrandedItemsResolutionHandler<org.apache.commons.lang3.tuple.Pair<PK,Integer>> - Parameters:
itemsToResolve- items to check whether indeed should be resolvedcontextProvider- the context provided that can be used to get additional data for given item (if provided when marking the item as stranded)- Returns:
- the items that should be resolved. The items passed in
itemsToResolveand not returned by this method will be marked as checked (removed from stranded items registry)
-
resolveStrandedItems
public Set<PK> resolveStrandedItems(List<org.apache.commons.lang3.tuple.Pair<PK, Integer>> itemsToResolve, StrandedItemsRegistry.StrandedItemContextProvider contextProvider) Description copied from class:StrandedItemsRegistry.StrandedItemsResolutionHandlerThe method to resolve the stranded items.- Specified by:
resolveStrandedItemsin classStrandedItemsRegistry.StrandedItemsResolutionHandler<org.apache.commons.lang3.tuple.Pair<PK,Integer>> - Parameters:
itemsToResolve- items to resolvecontextProvider- the context provided that can be used to get additional data for given item (if provided when marking the item as stranded)- Returns:
- the collection of items' PKs that has been successfully resolved. The items returned by this method wiil be marked
as checked (removed from stranded items registry). The items not retuned by this method but passed in
itemsToResolvewill NOT be removed from stranded items registry and could be checked again during one of next executions of this method.
-
getItemPk
Description copied from class:StrandedItemsRegistry.StrandedItemsResolutionHandlerMethod to obtain the PK of item returned byStrandedItemsRegistry.StrandedItemsResolutionHandler.filterItemsToResolve(Set, StrandedItemContextProvider)- Specified by:
getItemPkin classStrandedItemsRegistry.StrandedItemsResolutionHandler<org.apache.commons.lang3.tuple.Pair<PK,Integer>> - Returns:
-