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

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.
static ExecutorServiceBuilder	defaultQueryResponseExecutorServiceBuilder() Create a default ExecutorServiceBuilder used to create a ThreadPoolExecutor for processing incoming query responses.

Methods inherited from interface java.util.function.BiFunction

andThen, apply

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, 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, the given BlockingQueue as the workQueue and an AxonThreadFactory.

Returns:

a default ExecutorServiceBuilder to create an executor for processing queries

defaultQueryResponseExecutorServiceBuilder

static ExecutorServiceBuilder defaultQueryResponseExecutorServiceBuilder()

Create a default ExecutorServiceBuilder used to create a ThreadPoolExecutor for processing incoming query responses. Uses the AxonServerConfiguration.getQueryResponseThreads() as the core and maximum pool size, the given BlockingQueue as the workQueue and an AxonThreadFactory.

Returns:

a default ExecutorServiceBuilder to create an executor for processing incoming query responses