org.axonframework.axonserver.connector.util

Interface PriorityTaskSchedulers

public interface PriorityTaskSchedulers

Responsible for creating Scheduler implementations relevant to the Axon Server connector.

Since:

4.6.0

Author:

Mitchell Herrijgers, Milan Savic

Method Summary

Modifier and Type	Method and Description
static reactor.core.scheduler.Scheduler	forPriority(ExecutorService delegate, long priority, AtomicLong taskSequence) Creates a Scheduler that is compatible with an ExecutorService that needs tasks that are submitted to be a PriorityTask so that they can be prioritized.

Method Detail

forPriority

static reactor.core.scheduler.Scheduler forPriority(ExecutorService delegate,
                                                    long priority,
                                                    AtomicLong taskSequence)

Creates a Scheduler that is compatible with an ExecutorService that needs tasks that are submitted to be a PriorityTask so that they can be prioritized.

Parameters:

delegate - The delegate ExecutorService to use when submitting tasks.

priority - The priority that any tasks submitted to the delegate will have.

taskSequence - The task sequence used for ordering items with the same priority.

Returns:

The Scheduler object that is compatible with PriorityTask.

See Also:

PriorityExecutorService