Package 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

    Static Methods
    Modifier and Type
    Method
    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 Details

    • 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: