org.kie.server.services.taskassigning.planning

Class SolutionSynchronizer

java.lang.Object

org.kie.server.services.taskassigning.planning.RunnableBase

org.kie.server.services.taskassigning.planning.SolutionSynchronizer

All Implemented Interfaces:

Runnable

public class SolutionSynchronizer
extends RunnableBase

This class manages the periodical reading (polling strategy) of current tasks from the jBPM runtime and depending on the "action" INIT_SOLVER_EXECUTOR / SYNCHRONIZE_SOLUTION determines if the solver executor must be restarted with a fully recovered solution or instead the tasks updated information is used for calculating the required changes for the proper solution update. If any changes are calculated they are notified to the resultConsumer. This class implements proper retries in case of connection issues with the target jBPM runtime, etc.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SolutionSynchronizer.Result

Nested classes/interfaces inherited from class org.kie.server.services.taskassigning.planning.RunnableBase

RunnableBase.Status

Field Summary

Fields inherited from class org.kie.server.services.taskassigning.planning.RunnableBase

status

Constructor Summary

Constructors

Constructor and Description
SolutionSynchronizer(SolverExecutor solverExecutor, TaskAssigningRuntimeDelegate delegate, org.kie.server.services.taskassigning.user.system.api.UserSystemService userSystem, Duration syncInterval, Duration usersSyncInterval, SolverHandlerContext context, Consumer<SolutionSynchronizer.Result> resultConsumer)

Method Summary

Modifier and Type	Method and Description
protected List<org.optaplanner.core.impl.solver.ProblemFactChange<TaskAssigningSolution>>	buildChanges(TaskAssigningSolution solution, List<org.kie.server.api.model.taskassigning.TaskData> updatedTaskDataList)
protected List<org.optaplanner.core.impl.solver.ProblemFactChange<TaskAssigningSolution>>	buildChanges(TaskAssigningSolution solution, List<org.kie.server.api.model.taskassigning.TaskData> updatedTaskDataList, List<org.kie.server.services.taskassigning.user.system.api.User> updatedUserList)
protected List<org.optaplanner.core.impl.solver.ProblemFactChange<TaskAssigningSolution>>	buildChanges(TaskAssigningSolution solution, org.apache.commons.lang3.tuple.Pair<List<org.kie.server.api.model.taskassigning.TaskData>,LocalDateTime> tasksUpdateResult, org.apache.commons.lang3.tuple.Pair<Boolean,List<org.kie.server.services.taskassigning.user.system.api.User>> usersUpdateResult)
protected TaskAssigningSolution	buildSolution(List<org.kie.server.api.model.taskassigning.TaskData> taskDataList, List<org.kie.server.services.taskassigning.user.system.api.User> externalUsers)
protected long	calculateNextUsersSyncTime()
void	destroy() Starts the synchronizing finalization, that will be produced as soon as possible.
void	initSolverExecutor()
protected boolean	isUsersSyncTime()
void	run()
void	synchronizeSolution(TaskAssigningSolution solution, LocalDateTime fromLastModificationDate)

Methods inherited from class org.kie.server.services.taskassigning.planning.RunnableBase

isAlive, isDestroyed

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SolutionSynchronizer

public SolutionSynchronizer(SolverExecutor solverExecutor,
                            TaskAssigningRuntimeDelegate delegate,
                            org.kie.server.services.taskassigning.user.system.api.UserSystemService userSystem,
                            Duration syncInterval,
                            Duration usersSyncInterval,
                            SolverHandlerContext context,
                            Consumer<SolutionSynchronizer.Result> resultConsumer)

Method Detail

initSolverExecutor

public void initSolverExecutor()

synchronizeSolution

public void synchronizeSolution(TaskAssigningSolution solution,
                                LocalDateTime fromLastModificationDate)

destroy

public void destroy()

Starts the synchronizing finalization, that will be produced as soon as possible. It's a non thread-safe method, but only first invocation has effect.

Overrides:

destroy in class RunnableBase

run

public void run()

isUsersSyncTime

protected boolean isUsersSyncTime()

calculateNextUsersSyncTime

protected long calculateNextUsersSyncTime()

buildChanges

protected List<org.optaplanner.core.impl.solver.ProblemFactChange<TaskAssigningSolution>> buildChanges(TaskAssigningSolution solution,
                                                                                                       org.apache.commons.lang3.tuple.Pair<List<org.kie.server.api.model.taskassigning.TaskData>,LocalDateTime> tasksUpdateResult,
                                                                                                       org.apache.commons.lang3.tuple.Pair<Boolean,List<org.kie.server.services.taskassigning.user.system.api.User>> usersUpdateResult)

buildChanges

protected List<org.optaplanner.core.impl.solver.ProblemFactChange<TaskAssigningSolution>> buildChanges(TaskAssigningSolution solution,
                                                                                                       List<org.kie.server.api.model.taskassigning.TaskData> updatedTaskDataList)

buildChanges

protected List<org.optaplanner.core.impl.solver.ProblemFactChange<TaskAssigningSolution>> buildChanges(TaskAssigningSolution solution,
                                                                                                       List<org.kie.server.api.model.taskassigning.TaskData> updatedTaskDataList,
                                                                                                       List<org.kie.server.services.taskassigning.user.system.api.User> updatedUserList)

buildSolution

protected TaskAssigningSolution buildSolution(List<org.kie.server.api.model.taskassigning.TaskData> taskDataList,
                                              List<org.kie.server.services.taskassigning.user.system.api.User> externalUsers)