org.kie.server.services.taskassigning.planning

Class SolverHandlerContext

java.lang.Object

org.kie.server.services.taskassigning.planning.SolverHandlerContext

public class SolverHandlerContext
extends Object

Constructor Summary

Constructors

Constructor and Description
SolverHandlerContext(int queryTimesSize, long queryMinimumDistance)

Method Summary

Modifier and Type	Method and Description
void	addNextQueryTime(LocalDateTime nextQueryTime) Adds a new value to the available query times.
void	clearProcessedChangeSet()
void	clearTaskChangeTimes() Removes all the registered task time changes.
void	clearTaskChangeTimes(LocalDateTime untilLocalDateTime) Removes all the registered task change times that occurred strictly before a given time.
long	getCurrentChangeSetId()
LocalDateTime	getPreviousQueryTime() Gets the previously executed query time.
boolean	hasMinimalDistance(LocalDateTime lastQueryTime, LocalDateTime nextQueryTime) Indicates if two query times has the minimum configured separation.
boolean	isProcessedChangeSet(long changeSetId)
boolean	isProcessedTaskChange(long taskId, LocalDateTime changeTime) Indicates if a change has already been processed for a given task.
long	nextChangeSetId()
LocalDateTime	peekLastQueryTime()
LocalDateTime	pollLastQueryTime() Retrieves and removes the last available query time.
LocalDateTime	pollNextQueryTime() Retrieves and removes the first available query time to process.
void	resetQueryTimes(LocalDateTime startValue) Resets the registered query times by using a start value.
void	setCurrentChangeSetId(long currentChangeSetId)
void	setPreviousQueryTime(LocalDateTime previousQueryTime) Sets the previously executed query time.
void	setProcessedChangeSet(long changeSetId)
void	setTaskChangeTime(long taskId, LocalDateTime changeTime) Registers the time of the last change processed for a task.

Methods inherited from class java.lang.Object

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

Constructor Detail

SolverHandlerContext

public SolverHandlerContext(int queryTimesSize,
                            long queryMinimumDistance)

Method Detail

getCurrentChangeSetId

public long getCurrentChangeSetId()

setCurrentChangeSetId

public void setCurrentChangeSetId(long currentChangeSetId)

nextChangeSetId

public long nextChangeSetId()

isProcessedChangeSet

public boolean isProcessedChangeSet(long changeSetId)

setProcessedChangeSet

public void setProcessedChangeSet(long changeSetId)

clearProcessedChangeSet

public void clearProcessedChangeSet()

setTaskChangeTime

public void setTaskChangeTime(long taskId,
                              LocalDateTime changeTime)

Registers the time of the last change processed for a task.

Parameters:

taskId - identifier of the task to register.

changeTime - the task change time to register.

isProcessedTaskChange

public boolean isProcessedTaskChange(long taskId,
                                     LocalDateTime changeTime)

Indicates if a change has already been processed for a given task.

Parameters:

taskId - identifier of the task to query.

changeTime - the task change time to query.

Returns:

true if the change has already been processed, false in any other case.

clearTaskChangeTimes

public void clearTaskChangeTimes(LocalDateTime untilLocalDateTime)

Removes all the registered task change times that occurred strictly before a given time.

Parameters:

untilLocalDateTime - the time for filtering the changes to remove.

clearTaskChangeTimes

public void clearTaskChangeTimes()

Removes all the registered task time changes.

getPreviousQueryTime

public LocalDateTime getPreviousQueryTime()

Gets the previously executed query time.

Returns:

the previously executed query time

setPreviousQueryTime

public void setPreviousQueryTime(LocalDateTime previousQueryTime)

Sets the previously executed query time.

Parameters:

previousQueryTime - the query time to set.

resetQueryTimes

public void resetQueryTimes(LocalDateTime startValue)

Resets the registered query times by using a start value.

Parameters:

startValue - the start value for filling the initial query times.

pollNextQueryTime

public LocalDateTime pollNextQueryTime()

Retrieves and removes the first available query time to process.

Returns:

the next available query time.

pollLastQueryTime

public LocalDateTime pollLastQueryTime()

Retrieves and removes the last available query time.

Returns:

the last available query time.

peekLastQueryTime

public LocalDateTime peekLastQueryTime()

addNextQueryTime

public void addNextQueryTime(LocalDateTime nextQueryTime)

Adds a new value to the available query times.

Parameters:

nextQueryTime - the value to add.

hasMinimalDistance

public boolean hasMinimalDistance(LocalDateTime lastQueryTime,
                                  LocalDateTime nextQueryTime)

Indicates if two query times has the minimum configured separation.

Parameters:

lastQueryTime - the previous query time for the calculation.

nextQueryTime - the next query time for the calculation.

Returns:

true if the distance between the query times is at least the expected one, false in any other case.