RoundRobinWorkflowStrategy (tasktide API)

java.lang.Object

org.tasktide.engine.policies.workflow.AbstractWorkflowStrategy

org.tasktide.engine.policies.workflow.RoundRobinWorkflowStrategy

All Implemented Interfaces:: WorkflowAcquisitionStrategy

public class RoundRobinWorkflowStrategy extends AbstractWorkflowStrategy

Round robin strategy to consume steps of workflow FIFO queue

Field Summary

Fields inherited from class AbstractWorkflowStrategy
activePolicy, counter, hasRun, id, limit, mode, policies, workflow
Method Summary

Modifier and Type

Method

Description

void

configureDefaultStrategyMode()

Configure default scanning WorkflowStrategyMode for WorkflowAcquisitionStrategy

List<WorkItem>

evaluateWorkload(List<WorkItem> workload)

Evaluate retrieved workload to configured WorkflowStrategyMode

List<WorkItem>

fetchWorkload()

Fetches WorkItem collection according to configured TaskTideWorkloadAcquisitionPolicy.

boolean

hasNext()

Checks whether there active tasks in workflow, bypassing count of records

Methods inherited from class AbstractWorkflowStrategy
evaluateIterationCounter, getActive, getHasRun, getId, getIterationLimit, getQueueTargets, getStrategyMode, getTargetNames, resetPolicyQueue, setHasRun, setIterationLimit, setStrategyMode

Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- fetchWorkload
  
  public List<WorkItem> fetchWorkload()
  
  Fetches WorkItem collection according to configured TaskTideWorkloadAcquisitionPolicy. Stateless round robin processing of steps in the workflow, where flow is determined by the configured WorkflowStrategyMode
  
  Returns:
  
  List-WorkItem
- configureDefaultStrategyMode
  
  public void configureDefaultStrategyMode()
  
  Configure default scanning WorkflowStrategyMode for WorkflowAcquisitionStrategy
- evaluateWorkload
  
  public List<WorkItem> evaluateWorkload(List<WorkItem> workload)
  
  Evaluate retrieved workload to configured WorkflowStrategyMode
  
  Parameters:
  
  workload -
  
  Returns:
  
  List-WorkItem
- hasNext
  
  public boolean hasNext()
  
  Checks whether there active tasks in workflow, bypassing count of records
  
  Specified by:
  
  hasNext in interface WorkflowAcquisitionStrategy
  
  Overrides:
  
  hasNext in class AbstractWorkflowStrategy
  
  Returns:
  
  boolean