org.axonframework.axonserver.connector.event.axon

Interface PersistentStreamScheduledExecutorBuilder

All Superinterfaces:

BiFunction<Integer,String,ScheduledExecutorService>

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 PersistentStreamScheduledExecutorBuilder
extends BiFunction<Integer,String,ScheduledExecutorService>

Functional interface towards constructing a ScheduledExecutorService for a PersistentStreamMessageSource.

Since:

4.10.1

Author:

Steven van Beelen

Method Summary

Modifier and Type	Method and Description
default ScheduledExecutorService	build(Integer threadCount, String streamName) Builds a ScheduledExecutorService using the given threadCount and streamName.
static PersistentStreamScheduledExecutorBuilder	defaultFactory() Default PersistentStreamScheduledExecutorBuilder.

Methods inherited from interface java.util.function.BiFunction

andThen, apply

Method Detail

build

default ScheduledExecutorService build(Integer threadCount,
                                       String streamName)

Builds a ScheduledExecutorService using the given threadCount and streamName.

Parameters:

threadCount - The requested thread count for the persistent stream. Can for example be used to define the pool size of the ScheduledExecutorService under construction.

streamName - The name of the persistent stream. Can, for example, be used to define the name of the ThreadFactory given to a ScheduledExecutorService

Returns:

A ScheduledExecutorService based on the given threadCount and streamName.

defaultFactory

static PersistentStreamScheduledExecutorBuilder defaultFactory()

Default PersistentStreamScheduledExecutorBuilder. Constructs a ScheduledExecutorService by using the given threadCount as the pool size for the executor. Uses the given streamName to build an AxonThreadFactory with the group name "PersistentStream[{streamName}]".

Returns:

The default PersistentStreamScheduledExecutorBuilder.