Class FluxzeroSpringConfig

java.lang.Object

io.fluxzero.sdk.configuration.spring.FluxzeroSpringConfig

All Implemented Interfaces:

org.springframework.beans.factory.config.BeanPostProcessor

@Configuration
public class FluxzeroSpringConfig
extends Object
implements org.springframework.beans.factory.config.BeanPostProcessor

Spring configuration class for automatically wiring and initializing common Fluxzero components in a Spring application context.

This configuration simplifies the integration of Fluxzero by:

• Registering @Handle... annotated beans as handlers after the context is refreshed
• Auto-detecting and registering upcasters and downcasters with the Serializer
• Providing default implementations for core interfaces like CommandGateway, Serializer, and MessageScheduler

Note that Fluxzero does not require Spring, and this class is entirely optional. It exists purely to reduce boilerplate in Spring-based applications.

The simplest way to enable this configuration in a Spring Boot application, is by annotating your main application class with:

@SpringBootApplication
@Import(FluxzeroSpringConfig.class)

See Also:

• Fluxzero
• FluxzeroBuilder

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FluxzeroSpringConfig(org.springframework.context.ApplicationContext context)	Stores a reference to the Spring context and prepares for handler detection.

Method Summary

Modifier and Type	Method	Description
AggregateRepository	aggregateRepository(Fluxzero fluxzero)
CommandGateway	commandGateway(Fluxzero fluxzero)
DocumentStore	documentStore(Fluxzero fluxzero)
ErrorGateway	errorGateway(Fluxzero fluxzero)
EventGateway	eventGateway(Fluxzero fluxzero)
Fluxzero	fluxzero(FluxzeroBuilder builder, List<FluxzeroCustomizer> customizers)	Constructs the Fluxzero instance if no Fluxzero bean exists, preferring a user-provided Client or falling back to either a WebSocketClient or LocalClient depending on presence of configuration properties.
FluxzeroBuilder	fluxzeroBuilder(Serializer serializer, Optional<UserProvider> userProvider, Optional<Cache> cache, Optional<WebResponseMapper> webResponseMapper, org.springframework.core.env.Environment environment)	Provides a default FluxzeroBuilder, configured using Spring-provided components such as UserProvider, Cache, and WebResponseMapper.
protected <T> Optional<T>	getBean(Class<T> type)
void	handle(org.springframework.context.event.ContextRefreshedEvent event)	Registers all discovered Spring beans as Fluxzero handlers once the application context is refreshed.
KeyValueStore	keyValueStore(Fluxzero fluxzero)
MetricsGateway	metricsGateway(Fluxzero fluxzero)
Object	postProcessAfterInitialization(Object bean, String beanName)	Captures beans post-initialization to inspect later for handler registration.
QueryGateway	queryGateway(Fluxzero fluxzero)
ResultGateway	resultGateway(Fluxzero fluxzero)
MessageScheduler	scheduler(Fluxzero fluxzero)
Serializer	serializer()	Optionally provides a default Serializer implementation based on Jackson, automatically detecting and registering upcasters and downcasters from Spring-managed beans.
static SocketEndpointPostProcessor	socketEndpointPostProcessor()	Registers the SocketEndpointPostProcessor, used for handlers that manage WebSocket communication.
static StatefulPostProcessor	statefulPostProcessor()	Registers the StatefulPostProcessor, enabling lifecycle and stateful behavior for beans.
static TrackSelfPostProcessor	trackSelfPostProcessor()	Registers the TrackSelfPostProcessor, which supports payload classes that track and handle their own type.

Methods inherited from class Object

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

Methods inherited from interface org.springframework.beans.factory.config.BeanPostProcessor

postProcessBeforeInitialization

Constructor Details

FluxzeroSpringConfig

@Autowired
protected FluxzeroSpringConfig(org.springframework.context.ApplicationContext context)

Stores a reference to the Spring context and prepares for handler detection.

Method Details

trackSelfPostProcessor

@Bean
public static TrackSelfPostProcessor trackSelfPostProcessor()

Registers the TrackSelfPostProcessor, which supports payload classes that track and handle their own type.

See Also:

• TrackSelf

statefulPostProcessor

@Bean
public static StatefulPostProcessor statefulPostProcessor()

Registers the StatefulPostProcessor, enabling lifecycle and stateful behavior for beans.

See Also:

• Stateful

socketEndpointPostProcessor

@Bean
public static SocketEndpointPostProcessor socketEndpointPostProcessor()

Registers the SocketEndpointPostProcessor, used for handlers that manage WebSocket communication.

See Also:

• SocketEndpoint

postProcessAfterInitialization

public Object postProcessAfterInitialization(Object bean,
 String beanName)
                                      throws org.springframework.beans.BeansException

Captures beans post-initialization to inspect later for handler registration. Prototype beans are handled specially.

Specified by:

postProcessAfterInitialization in interface org.springframework.beans.factory.config.BeanPostProcessor

Throws:

org.springframework.beans.BeansException

handle

@EventListener
public void handle(org.springframework.context.event.ContextRefreshedEvent event)

Registers all discovered Spring beans as Fluxzero handlers once the application context is refreshed. Also installs a default uncaught exception handler and starts the application context if needed.

serializer

@Bean
public Serializer serializer()

Optionally provides a default Serializer implementation based on Jackson, automatically detecting and registering upcasters and downcasters from Spring-managed beans.

This method is only invoked if no other Serializer bean is defined.

If a custom serializer is provided by the application, upcasters and downcasters must be registered explicitly.

Returns:

a Serializer configured with discovered casting logic

fluxzeroBuilder

@Bean
public FluxzeroBuilder fluxzeroBuilder(Serializer serializer,
 Optional<UserProvider> userProvider,
 Optional<Cache> cache,
 Optional<WebResponseMapper> webResponseMapper,
 org.springframework.core.env.Environment environment)

Provides a default FluxzeroBuilder, configured using Spring-provided components such as UserProvider, Cache, and WebResponseMapper. Automatically uses application properties via SpringPropertySource.

fluxzero

@Bean
public Fluxzero fluxzero(FluxzeroBuilder builder,
 List<FluxzeroCustomizer> customizers)

Constructs the Fluxzero instance if no Fluxzero bean exists, preferring a user-provided Client or falling back to either a WebSocketClient or LocalClient depending on presence of configuration properties.

aggregateRepository

@Bean
public AggregateRepository aggregateRepository(Fluxzero fluxzero)

scheduler

@Bean
public MessageScheduler scheduler(Fluxzero fluxzero)

commandGateway

@Bean
public CommandGateway commandGateway(Fluxzero fluxzero)

eventGateway

@Bean
public EventGateway eventGateway(Fluxzero fluxzero)

queryGateway

@Bean
public QueryGateway queryGateway(Fluxzero fluxzero)

errorGateway

@Bean
public ErrorGateway errorGateway(Fluxzero fluxzero)

metricsGateway

@Bean
public MetricsGateway metricsGateway(Fluxzero fluxzero)

resultGateway

@Bean
public ResultGateway resultGateway(Fluxzero fluxzero)

keyValueStore

@Bean
public KeyValueStore keyValueStore(Fluxzero fluxzero)

documentStore

@Bean
public DocumentStore documentStore(Fluxzero fluxzero)

getBean

protected <T> Optional<T> getBean(Class<T> type)