Package org.axonframework.common.util

Class PriorityCallable<T>

java.lang.Object

org.axonframework.common.util.PriorityCallable<T>

Type Parameters:

T - The type of the result returned by the Callable.call() method.

All Implemented Interfaces:

Comparable<PriorityTask>, Callable<T>, PriorityTask

public class PriorityCallable<T>
extends Object
implements Callable<T>, PriorityTask

A wrapper class of Callables that adheres to a priority by implementing PriorityTask. Uses a combination of priority and index to compare between this and other priority task instances. A calculator (e.g.

invalid reference

org.axonframework.commandhandling.CommandPriorityCalculator

) defines the priority of the task. This task uses the index to differentiate between tasks with the same priority, ensuring the insert order is leading in those scenarios.

Since:

4.6.0

Author:

Stefan Dragisic, Milan Savic, Allard Buijze, Steven van Beelen, Mitchell Herrijgers

Constructor Summary

Constructors

Constructor	Description
PriorityCallable(Callable<T> task, long priority, long sequence)	Construct a priority task.

Method Summary

Modifier and Type	Method	Description
T	call()
boolean	equals(Object o)
int	hashCode()
long	priority()	Returns the priority of this task.
long	sequence()	Returns the sequence of this task.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.axonframework.common.util.PriorityTask

compareTo

Constructor Details

PriorityCallable

public PriorityCallable(Callable<T> task,
 long priority,
 long sequence)

Construct a priority task.

Parameters:

task - The Callable<T> that should be executed with a priority.

priority - The priority of the task to execute, dedicating the order among tasks.

sequence - The sequence of the task to execute, dedicating the order among equal priority tasks.

Method Details

call

public T call()
       throws Exception

Specified by:

call in interface Callable<T>

Throws:

Exception

priority

public long priority()

Description copied from interface: PriorityTask

Returns the priority of this task.

Specified by:

priority in interface PriorityTask

Returns:

The priority of this task.

sequence

public long sequence()

Description copied from interface: PriorityTask

Returns the sequence of this task.

Specified by:

sequence in interface PriorityTask

Returns:

The sequence of this task.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object