Uses of Interface
io.fluxzero.sdk.configuration.FluxzeroBuilder
Packages that use FluxzeroBuilder
-
Uses of FluxzeroBuilder in io.fluxzero.sdk.configuration
Classes in io.fluxzero.sdk.configuration that implement FluxzeroBuilderMethods in io.fluxzero.sdk.configuration that return FluxzeroBuilderModifier and TypeMethodDescriptionDefaultFluxzero.Builder.addBatchInterceptor(BatchInterceptor interceptor, MessageType... forTypes) FluxzeroBuilder.addBatchInterceptor(BatchInterceptor interceptor, MessageType... forTypes) Registers aBatchInterceptorthat applies to the given message types.FluxzeroBuilder.addConsumerConfiguration(ConsumerConfiguration consumerConfiguration, MessageType... messageTypes) Adds a specific consumer configuration for one or more message types.FluxzeroBuilder.addDispatchInterceptor(DispatchInterceptor interceptor, boolean highPriority, MessageType... forTypes) Adds aDispatchInterceptorfor specified message types with optional priority.default FluxzeroBuilderFluxzeroBuilder.addDispatchInterceptor(DispatchInterceptor interceptor, MessageType... forTypes) Adds aDispatchInterceptorthat modifies or monitors message dispatch.FluxzeroBuilder.addHandlerDecorator(HandlerDecorator decorator, boolean highPriority, MessageType... forTypes) Adds aHandlerDecoratorwith control over priority.default FluxzeroBuilderFluxzeroBuilder.addHandlerDecorator(HandlerDecorator decorator, MessageType... forTypes) Adds aHandlerDecoratorfor the given message types.default FluxzeroBuilderFluxzeroBuilder.addHandlerInterceptor(HandlerInterceptor interceptor, boolean highPriority, MessageType... forTypes) Adds aHandlerInterceptorwith specified priority.default FluxzeroBuilderFluxzeroBuilder.addHandlerInterceptor(HandlerInterceptor interceptor, MessageType... forTypes) Adds aHandlerInterceptorfor given message types.FluxzeroBuilder.addParameterResolver(ParameterResolver<? super DeserializingMessage> parameterResolver) Registers aParameterResolverto support injection of method arguments in handlers.default FluxzeroBuilderFluxzeroBuilder.addPropertySource(PropertySource propertySource) Adds aPropertySourceto the configuration chain.FluxzeroBuilder.configureDefaultConsumer(MessageType messageType, UnaryOperator<ConsumerConfiguration> updateFunction) Update the default consumer configuration for the specified message type.DefaultFluxzero.Builder.disableAdhocDispatchInterceptor()FluxzeroBuilder.disableAdhocDispatchInterceptor()Disables support for dynamically injected dispatch interceptors.DefaultFluxzero.Builder.disableAutomaticAggregateCaching()FluxzeroBuilder.disableAutomaticAggregateCaching()Disables automatic caching of aggregates.default FluxzeroBuilderFluxzeroBuilder.disableAutomaticTracking()Helper method that disables all processes that contain automatic trackers.DefaultFluxzero.Builder.disableCacheEvictionMetrics()FluxzeroBuilder.disableCacheEvictionMetrics()Disables metrics related to cache eviction.DefaultFluxzero.Builder.disableDataProtection()FluxzeroBuilder.disableDataProtection()Disables security filtering based on@FilterContent.DefaultFluxzero.Builder.disableErrorReporting()FluxzeroBuilder.disableErrorReporting()Disables automatic error reporting (e.g., viaErrorGateway).DefaultFluxzero.Builder.disableKeepalive()FluxzeroBuilder.disableKeepalive()Disables Fluxzero’s built-in keepalive mechanism.FluxzeroBuilder.disableMessageCorrelation()Disables automatic message correlation.FluxzeroBuilder.disablePayloadValidation()Disables payload validation.DefaultFluxzero.Builder.disableScheduledCommandHandler()FluxzeroBuilder.disableScheduledCommandHandler()Prevents installation of the default scheduled command handler.DefaultFluxzero.Builder.disableShutdownHook()FluxzeroBuilder.disableShutdownHook()Prevents registration of a shutdown hook.DefaultFluxzero.Builder.disableTrackingMetrics()FluxzeroBuilder.disableTrackingMetrics()Disables tracking of processing metrics.DefaultFluxzero.Builder.disableWebResponseCompression()FluxzeroBuilder.disableWebResponseCompression()Disables compression for web responses.DefaultFluxzero.Builder.forwardWebRequestsToLocalServer(LocalServerConfig localServerConfig, UnaryOperator<ConsumerConfiguration> consumerConfigurator) default FluxzeroBuilderFluxzeroBuilder.forwardWebRequestsToLocalServer(int port) Forwards incomingMessageType.WEBREQUESTmessages to a locally running HTTP server on the specified port.FluxzeroBuilder.forwardWebRequestsToLocalServer(LocalServerConfig localServerConfig, UnaryOperator<ConsumerConfiguration> consumerConfigurator) Configures forwarding ofMessageType.WEBREQUESTmessages to a local HTTP server using the specifiedLocalServerConfigand custom consumer configuration.DefaultFluxzero.Builder.makeApplicationInstance(boolean makeApplicationInstance) FluxzeroBuilder.makeApplicationInstance(boolean makeApplicationInstance) Marks the built instance as the global (application-level)Fluxzero.DefaultFluxzero.Builder.registerUserProvider(UserProvider userProvider) FluxzeroBuilder.registerUserProvider(UserProvider userProvider) Registers a user provider used for resolving and authenticatingUserinstances.DefaultFluxzero.Builder.replaceCache(@NonNull Cache cache) FluxzeroBuilder.replaceCache(Cache cache) Replaces the default cache implementation.DefaultFluxzero.Builder.replaceCorrelationDataProvider(@NonNull UnaryOperator<CorrelationDataProvider> replaceFunction) FluxzeroBuilder.replaceCorrelationDataProvider(UnaryOperator<CorrelationDataProvider> correlationDataProvider) Replaces theCorrelationDataProviderused to attach correlation data to messages.DefaultFluxzero.Builder.replaceDefaultResponseMapper(ResponseMapper defaultResponseMapper) FluxzeroBuilder.replaceDefaultResponseMapper(ResponseMapper responseMapper) Replaces the default response mapper used for generic result mapping.DefaultFluxzero.Builder.replaceDocumentSerializer(@NonNull DocumentSerializer documentSerializer) FluxzeroBuilder.replaceDocumentSerializer(DocumentSerializer documentSerializer) Replaces the document serializer for search indexing.DefaultFluxzero.Builder.replaceIdentityProvider(UnaryOperator<IdentityProvider> replaceFunction) FluxzeroBuilder.replaceIdentityProvider(UnaryOperator<IdentityProvider> replaceFunction) Replaces the identity provider used to generate message and entity identifiers.FluxzeroBuilder.replaceMessageRoutingInterceptor(DispatchInterceptor messageRoutingInterceptor) Replaces the default routing interceptor used for message dispatch.DefaultFluxzero.Builder.replacePropertySource(UnaryOperator<PropertySource> replacer) FluxzeroBuilder.replacePropertySource(UnaryOperator<PropertySource> replacer) Replaces the existing property source.DefaultFluxzero.Builder.replaceRelationshipsCache(UnaryOperator<Cache> replaceFunction) FluxzeroBuilder.replaceRelationshipsCache(UnaryOperator<Cache> replaceFunction) Replaces the internal relationships cache with a new implementation.FluxzeroBuilder.replaceSerializer(Serializer serializer) Replaces the default serializer used for events, commands, snapshots, and documents.FluxzeroBuilder.replaceSnapshotSerializer(Serializer serializer) Overrides the serializer used specifically for snapshot serialization.DefaultFluxzero.Builder.replaceTaskScheduler(Function<Clock, TaskScheduler> function) FluxzeroBuilder.replaceTaskScheduler(Function<Clock, TaskScheduler> function) Replaces the defaultTaskSchedulerimplementation.DefaultFluxzero.Builder.replaceWebResponseMapper(WebResponseMapper webResponseMapper) FluxzeroBuilder.replaceWebResponseMapper(WebResponseMapper webResponseMapper) Replaces theWebResponseMapperused for handling web responses.DefaultFluxzero.Builder.withAggregateCache(Class<?> aggregateType, Cache cache) FluxzeroBuilder.withAggregateCache(Class<?> aggregateType, Cache cache) Configures a dedicated cache for a specific aggregate type. -
Uses of FluxzeroBuilder in io.fluxzero.sdk.configuration.spring
Methods in io.fluxzero.sdk.configuration.spring that return FluxzeroBuilderModifier and TypeMethodDescriptionFluxzeroCustomizer.customize(FluxzeroBuilder builder) FluxzeroSpringConfig.fluxzeroBuilder(Serializer serializer, Optional<UserProvider> userProvider, Optional<Cache> cache, Optional<WebResponseMapper> webResponseMapper, org.springframework.core.env.Environment environment) Provides a defaultFluxzeroBuilder, configured using Spring-provided components such asUserProvider,Cache, andWebResponseMapper.Methods in io.fluxzero.sdk.configuration.spring with parameters of type FluxzeroBuilderModifier and TypeMethodDescriptionFluxzeroCustomizer.customize(FluxzeroBuilder builder) FluxzeroSpringConfig.fluxzero(FluxzeroBuilder builder, List<FluxzeroCustomizer> customizers) Constructs theFluxzeroinstance if no Fluxzero bean exists, preferring a user-providedClientor falling back to either aWebSocketClientorLocalClientdepending on presence of configuration properties.