Package io.axoniq.framework.axonserver.connector.event

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 PersistentStreamEventSource.

Since:

5.2.0

Author:

Steven van Beelen

Method Summary

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

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, which can for example be used to define the pool size of the ScheduledExecutorService under construction

streamName - the name of the persistent stream, which 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