org.axonframework.axonserver.connector.util

Interface ExecutorServiceBuilder

All Superinterfaces:

BiFunction<AxonServerConfiguration,BlockingQueue<Runnable>,ExecutorService>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface ExecutorServiceBuilder
extends BiFunction<AxonServerConfiguration,BlockingQueue<Runnable>,ExecutorService>

A Functional Interface towards a BiFunction which ingests both an AxonServerConfiguration and a BlockingQueue of Runnable, and outputs an ExecutorService. Provides a means to allow configuration of the used ExecutorService in for example the AxonServerCommandBus, but maintaining the option for the framework to provide a BlockingQueue which is tailored towards message prioritization when building the executor.

Since:

4.2

Author:

Steven van Beelen

Field Summary

Fields

Modifier and Type	Field and Description
static long	THREAD_KEEP_ALIVE_TIME

Method Summary

Modifier and Type	Method and Description
static ExecutorServiceBuilder	defaultCommandExecutorServiceBuilder() Create a default ExecutorServiceBuilder used to create a ThreadPoolExecutor for processing incoming commands.
static ExecutorServiceBuilder	defaultQueryExecutorServiceBuilder() Create a default ExecutorServiceBuilder used to create a ThreadPoolExecutor for processing incoming queries.

Methods inherited from interface java.util.function.BiFunction

andThen, apply

Field Detail

THREAD_KEEP_ALIVE_TIME

static final long THREAD_KEEP_ALIVE_TIME

See Also:

Constant Field Values

Method Detail

defaultCommandExecutorServiceBuilder

static ExecutorServiceBuilder defaultCommandExecutorServiceBuilder()

Create a default ExecutorServiceBuilder used to create a ThreadPoolExecutor for processing incoming commands. Uses the AxonServerConfiguration.getCommandThreads() as the core and maximum pool size, a keep-alive time of 100ms, the given BlockingQueue as the workQueue and an AxonThreadFactory.

Returns:

a default ExecutorServiceBuilder to create an executor for processing commands

defaultQueryExecutorServiceBuilder

static ExecutorServiceBuilder defaultQueryExecutorServiceBuilder()

Create a default ExecutorServiceBuilder used to create a ThreadPoolExecutor for processing incoming queries. Uses the AxonServerConfiguration.getQueryThreads() as the core and maximum pool size, a keep-alive time of 100ms, the given BlockingQueue as the workQueue and an AxonThreadFactory.

Returns:

a default ExecutorServiceBuilder to create an executor for processing queries