Class DefaultFluxzero.Builder

java.lang.Object

io.fluxzero.sdk.configuration.DefaultFluxzero.Builder

All Implemented Interfaces:

FluxzeroBuilder, FluxzeroConfiguration

Enclosing class:

DefaultFluxzero

public static class DefaultFluxzero.Builder
extends Object
implements FluxzeroBuilder

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
FluxzeroBuilder	addBatchInterceptor(BatchInterceptor interceptor, MessageType... forTypes)	Registers a BatchInterceptor that applies to the given message types.
DefaultFluxzero.Builder	addConsumerConfiguration(@NonNull ConsumerConfiguration configuration, MessageType... messageTypes)	Adds a specific consumer configuration for one or more message types.
DefaultFluxzero.Builder	addDispatchInterceptor(@NonNull DispatchInterceptor interceptor, MessageType... forTypes)	Adds a DispatchInterceptor that modifies or monitors message dispatch.
DefaultFluxzero.Builder	addHandlerDecorator(@NonNull HandlerDecorator interceptor, MessageType... forTypes)	Adds a HandlerDecorator for the given message types.
DefaultFluxzero.Builder	addParameterResolver(@NonNull ParameterResolver<? super DeserializingMessage> parameterResolver)	Registers a ParameterResolver to support injection of method arguments in handlers.
Fluxzero	build(@NonNull Client client)	Builds the Fluxzero instance using the provided low-level Client.
Cache	cache()	Default cache used for internal stateful optimizations (e.g. handler state, snapshots).
DefaultFluxzero.Builder	configureDefaultConsumer(@NonNull MessageType messageType, @NonNull UnaryOperator<ConsumerConfiguration> updateFunction)	Update the default consumer configuration for the specified message type.
protected GenericGateway	createRequestGateway(Client client, MessageType messageType, String topic, RequestHandler requestHandler, Map<MessageType, DispatchInterceptor> dispatchInterceptors, Map<MessageType, HandlerDecorator> handlerDecorators, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, Function<Class<?>, HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider, ResponseMapper responseMapper)
FluxzeroBuilder	disableAdhocDispatchInterceptor()	Disables support for dynamically injected dispatch interceptors.
FluxzeroBuilder	disableAutomaticAggregateCaching()	Disables automatic caching of aggregates.
FluxzeroBuilder	disableCacheEvictionMetrics()	Disables metrics related to cache eviction.
FluxzeroBuilder	disableDataProtection()	Disables security filtering based on @FilterContent.
FluxzeroBuilder	disableErrorReporting()	Disables automatic error reporting (e.g., via ErrorGateway).
FluxzeroBuilder	disableKeepalive()	Disables Fluxzero’s built-in keepalive mechanism.
DefaultFluxzero.Builder	disableMessageCorrelation()	Disables automatic message correlation.
DefaultFluxzero.Builder	disablePayloadValidation()	Disables payload validation.
FluxzeroBuilder	disableScheduledCommandHandler()	Prevents installation of the default scheduled command handler.
FluxzeroBuilder	disableShutdownHook()	Prevents registration of a shutdown hook.
FluxzeroBuilder	disableTrackingMetrics()	Disables tracking of processing metrics.
DefaultFluxzero.Builder	disableWebParameterValidation()	Disables validation of injected web parameters (e.g.
FluxzeroBuilder	disableWebResponseCompression()	Disables compression for web responses.
protected Fluxzero	doBuild(Map<MessageType, ? extends Tracking> trackingSupplier, Function<String, ? extends GenericGateway> customGatewaySupplier, CommandGateway commandGateway, QueryGateway queryGateway, EventGateway eventGateway, ResultGateway resultGateway, ErrorGateway errorGateway, MetricsGateway metricsGateway, WebRequestGateway webRequestGateway, AggregateRepository aggregateRepository, SnapshotStore snapshotStore, EventStore eventStore, KeyValueStore keyValueStore, DocumentStore documentStore, MessageScheduler messageScheduler, UserProvider userProvider, Cache cache, Serializer serializer, CorrelationDataProvider correlationDataProvider, IdentityProvider identityProvider, PropertySource propertySource, DelegatingClock clock, TaskScheduler taskScheduler, Client client, ThrowingRunnable shutdownHandler)
FluxzeroBuilder	enableHostMetrics(HostMetricsConfiguration configuration)	Enables host metrics collection with a custom configuration.
FluxzeroBuilder	forwardWebRequestsToLocalServer(LocalServerConfig localServerConfig, UnaryOperator<ConsumerConfiguration> consumerConfigurator)	Configures forwarding of MessageType.WEBREQUEST messages to a local HTTP server using the specified LocalServerConfig and custom consumer configuration.
protected ConsumerConfiguration	getDefaultConsumerConfiguration(MessageType messageType)
protected HandlerRegistry	localHandlerRegistry(MessageType messageType, Map<MessageType, HandlerDecorator> handlerDecorators, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, Map<MessageType, DispatchInterceptor> dispatchInterceptors, Function<Class<?>, HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider)
FluxzeroBuilder	makeApplicationInstance(boolean makeApplicationInstance)	Marks the built instance as the global (application-level) Fluxzero.
protected MethodInvocationValidator<? super DeserializingMessage>	methodInvocationValidator(MessageType messageType)
FluxzeroBuilder	registerUserProvider(UserProvider userProvider)	Registers a user provider used for resolving and authenticating User instances.
Cache	relationshipsCache()	Dedicated cache used to store and lookup relationships between entities.
FluxzeroBuilder	replaceCache(@NonNull Cache cache)	Replaces the default cache implementation.
FluxzeroBuilder	replaceCorrelationDataProvider(@NonNull UnaryOperator<CorrelationDataProvider> replaceFunction)	Replaces the CorrelationDataProvider used to attach correlation data to messages.
FluxzeroBuilder	replaceDefaultResponseMapper(ResponseMapper defaultResponseMapper)	Replaces the default response mapper used for generic result mapping.
FluxzeroBuilder	replaceDocumentSerializer(@NonNull DocumentSerializer documentSerializer)	Replaces the document serializer for search indexing.
FluxzeroBuilder	replaceIdentityProvider(UnaryOperator<IdentityProvider> replaceFunction)	Replaces the identity provider used to generate message and entity identifiers.
DefaultFluxzero.Builder	replaceMessageRoutingInterceptor(@NonNull DispatchInterceptor messageRoutingInterceptor)	Replaces the default routing interceptor used for message dispatch.
FluxzeroBuilder	replacePropertySource(UnaryOperator<PropertySource> replacer)	Replaces the existing property source.
FluxzeroBuilder	replaceRelationshipsCache(UnaryOperator<Cache> replaceFunction)	Replaces the internal relationships cache with a new implementation.
DefaultFluxzero.Builder	replaceSerializer(@NonNull Serializer serializer)	Replaces the default serializer used for events, commands, snapshots, and documents.
DefaultFluxzero.Builder	replaceSnapshotSerializer(@NonNull Serializer serializer)	Overrides the serializer used specifically for snapshot serialization.
FluxzeroBuilder	replaceTaskScheduler(Function<Clock, TaskScheduler> function)	Replaces the default TaskScheduler implementation.
FluxzeroBuilder	replaceWebResponseMapper(WebResponseMapper webResponseMapper)	Replaces the WebResponseMapper used for handling web responses.
FluxzeroBuilder	withAggregateCache(Class<?> aggregateType, Cache cache)	Configures a dedicated cache for a specific aggregate type.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface FluxzeroBuilder

addHandlerInterceptor, addPropertySource, disableAutomaticTracking, enableHostMetrics, enableHostMetrics, forwardWebRequestsToLocalServer

Methods inherited from interface FluxzeroConfiguration

batchInterceptors, clock, correlationDataProvider, customConsumerConfigurations, defaultConsumerConfigurations, defaultResponseMapper, dispatchInterceptors, documentSerializer, forwardingWebConsumer, handlerDecorators, identityProvider, makeApplicationInstance, messageRoutingInterceptor, parameterResolvers, propertySource, schedulingInterceptor, serializer, snapshotSerializer, taskScheduler, userProvider, webResponseMapper

Constructor Details

Builder

public Builder()

Method Details

replaceSerializer

public DefaultFluxzero.Builder replaceSerializer(@NonNull
 @NonNull Serializer serializer)

Description copied from interface: FluxzeroBuilder

Replaces the default serializer used for events, commands, snapshots, and documents.

Specified by:

replaceSerializer in interface FluxzeroBuilder

replaceCorrelationDataProvider

public FluxzeroBuilder replaceCorrelationDataProvider(@NonNull
 @NonNull UnaryOperator<CorrelationDataProvider> replaceFunction)

Description copied from interface: FluxzeroBuilder

Replaces the CorrelationDataProvider used to attach correlation data to messages.

Specified by:

replaceCorrelationDataProvider in interface FluxzeroBuilder

replaceSnapshotSerializer

public DefaultFluxzero.Builder replaceSnapshotSerializer(@NonNull
 @NonNull Serializer serializer)

Description copied from interface: FluxzeroBuilder

Overrides the serializer used specifically for snapshot serialization.

Specified by:

replaceSnapshotSerializer in interface FluxzeroBuilder

replaceDocumentSerializer

public FluxzeroBuilder replaceDocumentSerializer(@NonNull
 @NonNull DocumentSerializer documentSerializer)

Description copied from interface: FluxzeroBuilder

Replaces the document serializer for search indexing.

Specified by:

replaceDocumentSerializer in interface FluxzeroBuilder

registerUserProvider

public FluxzeroBuilder registerUserProvider(UserProvider userProvider)

Description copied from interface: FluxzeroBuilder

Registers a user provider used for resolving and authenticating User instances.

Specified by:

registerUserProvider in interface FluxzeroBuilder

replacePropertySource

public FluxzeroBuilder replacePropertySource(UnaryOperator<PropertySource> replacer)

Description copied from interface: FluxzeroBuilder

Replaces the existing property source.

Specified by:

replacePropertySource in interface FluxzeroBuilder

configureDefaultConsumer

public DefaultFluxzero.Builder configureDefaultConsumer(@NonNull
 @NonNull MessageType messageType,
 @NonNull
 @NonNull UnaryOperator<ConsumerConfiguration> updateFunction)

Description copied from interface: FluxzeroBuilder

Update the default consumer configuration for the specified message type.

Specified by:

configureDefaultConsumer in interface FluxzeroBuilder

addConsumerConfiguration

public DefaultFluxzero.Builder addConsumerConfiguration(@NonNull
 @NonNull ConsumerConfiguration configuration,
 MessageType... messageTypes)

Description copied from interface: FluxzeroBuilder

Adds a specific consumer configuration for one or more message types.

Specified by:

addConsumerConfiguration in interface FluxzeroBuilder

addBatchInterceptor

public FluxzeroBuilder addBatchInterceptor(BatchInterceptor interceptor,
 MessageType... forTypes)

Description copied from interface: FluxzeroBuilder

Registers a BatchInterceptor that applies to the given message types.

You can use @Order on the interceptor class to influence ordering. Lower values have higher priority. Interceptors with a negative order value run before Fluxzero's built-in batch interceptors, while zero, positive, or missing values run after them. Interceptors registered via Java's ServiceLoader are also picked up automatically and participate in the same ordering.

Specified by:

addBatchInterceptor in interface FluxzeroBuilder

addDispatchInterceptor

public DefaultFluxzero.Builder addDispatchInterceptor(@NonNull
 @NonNull DispatchInterceptor interceptor,
 MessageType... forTypes)

Description copied from interface: FluxzeroBuilder

Adds a DispatchInterceptor that modifies or monitors message dispatch.

You can use @Order on the interceptor class to influence ordering. Lower values have higher priority. Interceptors with a negative order value run in the high-priority slot, while zero, positive, or missing values run in the regular slot. Interceptors registered via Java's ServiceLoader are also picked up automatically and participate in the same ordering.

Specified by:

addDispatchInterceptor in interface FluxzeroBuilder

addHandlerDecorator

public DefaultFluxzero.Builder addHandlerDecorator(@NonNull
 @NonNull HandlerDecorator interceptor,
 MessageType... forTypes)

Description copied from interface: FluxzeroBuilder

Adds a HandlerDecorator for the given message types.

You can use @Order on the decorator class to influence ordering. Lower values have higher priority. Decorators with a negative order value run in the high-priority slot, while zero, positive, or missing values run in the regular slot. Decorators registered via Java's ServiceLoader are not discovered automatically; automatic service loading applies to interceptor interfaces.

Specified by:

addHandlerDecorator in interface FluxzeroBuilder

replaceMessageRoutingInterceptor

public DefaultFluxzero.Builder replaceMessageRoutingInterceptor(@NonNull
 @NonNull DispatchInterceptor messageRoutingInterceptor)

Description copied from interface: FluxzeroBuilder

Replaces the default routing interceptor used for message dispatch.

Specified by:

replaceMessageRoutingInterceptor in interface FluxzeroBuilder

replaceCache

public FluxzeroBuilder replaceCache(@NonNull
 @NonNull Cache cache)

Description copied from interface: FluxzeroBuilder

Replaces the default cache implementation.

Specified by:

replaceCache in interface FluxzeroBuilder

forwardWebRequestsToLocalServer

public FluxzeroBuilder forwardWebRequestsToLocalServer(LocalServerConfig localServerConfig,
 UnaryOperator<ConsumerConfiguration> consumerConfigurator)

Description copied from interface: FluxzeroBuilder

Configures forwarding of MessageType.WEBREQUEST messages to a local HTTP server using the specified LocalServerConfig and custom consumer configuration.

This mechanism is useful for advanced integration scenarios but bypasses Fluxzero's pull-based message tracking. Prefer native @HandleWeb handlers when possible.

Specified by:

forwardWebRequestsToLocalServer in interface FluxzeroBuilder

Parameters:

localServerConfig - configuration for the local server (e.g., port, error behavior)

consumerConfigurator - function to customize the underlying ConsumerConfiguration

Returns:

this builder instance

See Also:

• ForwardingWebConsumer

replaceDefaultResponseMapper

public FluxzeroBuilder replaceDefaultResponseMapper(ResponseMapper defaultResponseMapper)

Description copied from interface: FluxzeroBuilder

Replaces the default response mapper used for generic result mapping.

Specified by:

replaceDefaultResponseMapper in interface FluxzeroBuilder

replaceWebResponseMapper

public FluxzeroBuilder replaceWebResponseMapper(WebResponseMapper webResponseMapper)

Description copied from interface: FluxzeroBuilder

Replaces the WebResponseMapper used for handling web responses.

Specified by:

replaceWebResponseMapper in interface FluxzeroBuilder

replaceTaskScheduler

public FluxzeroBuilder replaceTaskScheduler(Function<Clock, TaskScheduler> function)

Description copied from interface: FluxzeroBuilder

Replaces the default TaskScheduler implementation.

Specified by:

replaceTaskScheduler in interface FluxzeroBuilder

withAggregateCache

public FluxzeroBuilder withAggregateCache(Class<?> aggregateType,
 Cache cache)

Description copied from interface: FluxzeroBuilder

Configures a dedicated cache for a specific aggregate type.

Specified by:

withAggregateCache in interface FluxzeroBuilder

replaceRelationshipsCache

public FluxzeroBuilder replaceRelationshipsCache(UnaryOperator<Cache> replaceFunction)

Description copied from interface: FluxzeroBuilder

Replaces the internal relationships cache with a new implementation.

Specified by:

replaceRelationshipsCache in interface FluxzeroBuilder

cache

public Cache cache()

Description copied from interface: FluxzeroConfiguration

Default cache used for internal stateful optimizations (e.g. handler state, snapshots).

Specified by:

cache in interface FluxzeroConfiguration

relationshipsCache

public Cache relationshipsCache()

Description copied from interface: FluxzeroConfiguration

Dedicated cache used to store and lookup relationships between entities.

Specified by:

relationshipsCache in interface FluxzeroConfiguration

replaceIdentityProvider

public FluxzeroBuilder replaceIdentityProvider(UnaryOperator<IdentityProvider> replaceFunction)

Description copied from interface: FluxzeroBuilder

Replaces the identity provider used to generate message and entity identifiers.

Specified by:

replaceIdentityProvider in interface FluxzeroBuilder

addParameterResolver

public DefaultFluxzero.Builder addParameterResolver(@NonNull
 @NonNull ParameterResolver<? super DeserializingMessage> parameterResolver)

Description copied from interface: FluxzeroBuilder

Registers a ParameterResolver to support injection of method arguments in handlers.

Specified by:

addParameterResolver in interface FluxzeroBuilder

disableErrorReporting

public FluxzeroBuilder disableErrorReporting()

Description copied from interface: FluxzeroBuilder

Disables automatic error reporting (e.g., via ErrorGateway).

Specified by:

disableErrorReporting in interface FluxzeroBuilder

disableShutdownHook

public FluxzeroBuilder disableShutdownHook()

Description copied from interface: FluxzeroBuilder

Prevents registration of a shutdown hook.

Specified by:

disableShutdownHook in interface FluxzeroBuilder

disableMessageCorrelation

public DefaultFluxzero.Builder disableMessageCorrelation()

Description copied from interface: FluxzeroBuilder

Disables automatic message correlation.

Specified by:

disableMessageCorrelation in interface FluxzeroBuilder

disablePayloadValidation

public DefaultFluxzero.Builder disablePayloadValidation()

Description copied from interface: FluxzeroBuilder

Disables payload validation.

Specified by:

disablePayloadValidation in interface FluxzeroBuilder

disableWebParameterValidation

public DefaultFluxzero.Builder disableWebParameterValidation()

Description copied from interface: FluxzeroBuilder

Disables validation of injected web parameters (e.g. @PathParam, @QueryParam).

Specified by:

disableWebParameterValidation in interface FluxzeroBuilder

disableDataProtection

public FluxzeroBuilder disableDataProtection()

Description copied from interface: FluxzeroBuilder

Disables security filtering based on @FilterContent.

Specified by:

disableDataProtection in interface FluxzeroBuilder

disableAutomaticAggregateCaching

public FluxzeroBuilder disableAutomaticAggregateCaching()

Description copied from interface: FluxzeroBuilder

Disables automatic caching of aggregates.

Specified by:

disableAutomaticAggregateCaching in interface FluxzeroBuilder

disableScheduledCommandHandler

public FluxzeroBuilder disableScheduledCommandHandler()

Description copied from interface: FluxzeroBuilder

Prevents installation of the default scheduled command handler.

Specified by:

disableScheduledCommandHandler in interface FluxzeroBuilder

disableTrackingMetrics

public FluxzeroBuilder disableTrackingMetrics()

Description copied from interface: FluxzeroBuilder

Disables tracking of processing metrics.

Specified by:

disableTrackingMetrics in interface FluxzeroBuilder

disableCacheEvictionMetrics

public FluxzeroBuilder disableCacheEvictionMetrics()

Description copied from interface: FluxzeroBuilder

Disables metrics related to cache eviction.

Specified by:

disableCacheEvictionMetrics in interface FluxzeroBuilder

disableWebResponseCompression

public FluxzeroBuilder disableWebResponseCompression()

Description copied from interface: FluxzeroBuilder

Disables compression for web responses.

Specified by:

disableWebResponseCompression in interface FluxzeroBuilder

disableAdhocDispatchInterceptor

public FluxzeroBuilder disableAdhocDispatchInterceptor()

Description copied from interface: FluxzeroBuilder

Disables support for dynamically injected dispatch interceptors.

Specified by:

disableAdhocDispatchInterceptor in interface FluxzeroBuilder

makeApplicationInstance

public FluxzeroBuilder makeApplicationInstance(boolean makeApplicationInstance)

Description copied from interface: FluxzeroBuilder

Marks the built instance as the global (application-level) Fluxzero.

Specified by:

makeApplicationInstance in interface FluxzeroBuilder

disableKeepalive

public FluxzeroBuilder disableKeepalive()

Description copied from interface: FluxzeroBuilder

Disables Fluxzero’s built-in keepalive mechanism.

By default, a Fluxzero instance keeps the JVM running after it is built by maintaining a single non-daemon thread. Calling this method disables that behavior, allowing the application to terminate normally once the main thread finishes.

Specified by:

disableKeepalive in interface FluxzeroBuilder

enableHostMetrics

public FluxzeroBuilder enableHostMetrics(HostMetricsConfiguration configuration)

Description copied from interface: FluxzeroBuilder

Enables host metrics collection with a custom configuration.

Specified by:

enableHostMetrics in interface FluxzeroBuilder

Parameters:

configuration - the host metrics configuration

Returns:

this builder instance

See Also:

• HostMetricsConfiguration

build

public Fluxzero build(@NonNull
 @NonNull Client client)

Description copied from interface: FluxzeroBuilder

Builds the Fluxzero instance using the provided low-level Client.

Specified by:

build in interface FluxzeroBuilder

doBuild

protected Fluxzero doBuild(Map<MessageType, ? extends Tracking> trackingSupplier,
 Function<String, ? extends GenericGateway> customGatewaySupplier,
 CommandGateway commandGateway,
 QueryGateway queryGateway,
 EventGateway eventGateway,
 ResultGateway resultGateway,
 ErrorGateway errorGateway,
 MetricsGateway metricsGateway,
 WebRequestGateway webRequestGateway,
 AggregateRepository aggregateRepository,
 SnapshotStore snapshotStore,
 EventStore eventStore,
 KeyValueStore keyValueStore,
 DocumentStore documentStore,
 MessageScheduler messageScheduler,
 UserProvider userProvider,
 Cache cache,
 Serializer serializer,
 CorrelationDataProvider correlationDataProvider,
 IdentityProvider identityProvider,
 PropertySource propertySource,
 DelegatingClock clock,
 TaskScheduler taskScheduler,
 Client client,
 ThrowingRunnable shutdownHandler)

getDefaultConsumerConfiguration

protected ConsumerConfiguration getDefaultConsumerConfiguration(MessageType messageType)

createRequestGateway

protected GenericGateway createRequestGateway(Client client,
 MessageType messageType,
 String topic,
 RequestHandler requestHandler,
 Map<MessageType, DispatchInterceptor> dispatchInterceptors,
 Map<MessageType, HandlerDecorator> handlerDecorators,
 List<ParameterResolver<? super DeserializingMessage>> parameterResolvers,
 Function<Class<?>, HandlerRepository> handlerRepositorySupplier,
 RepositoryProvider repositoryProvider,
 ResponseMapper responseMapper)

localHandlerRegistry

protected HandlerRegistry localHandlerRegistry(MessageType messageType,
 Map<MessageType, HandlerDecorator> handlerDecorators,
 List<ParameterResolver<? super DeserializingMessage>> parameterResolvers,
 Map<MessageType, DispatchInterceptor> dispatchInterceptors,
 Function<Class<?>, HandlerRepository> handlerRepositorySupplier,
 RepositoryProvider repositoryProvider)

methodInvocationValidator

protected MethodInvocationValidator<? super DeserializingMessage> methodInvocationValidator(MessageType messageType)