Package org.axonframework.extension.springboot.autoconfig

Class ReactorAutoConfiguration

java.lang.Object

org.axonframework.extension.springboot.autoconfig.ReactorAutoConfiguration

@AutoConfiguration
@AutoConfigureAfter(AxonAutoConfiguration.class)
@ConditionalOnClass(name={"reactor.core.publisher.Mono","org.axonframework.extension.reactor.messaging.core.ReactorMessageDispatchInterceptor"})
public class ReactorAutoConfiguration
extends Object

AutoConfiguration for the Axon Framework Reactor extension.

Discovers ReactorMessageDispatchInterceptor beans from the Spring application context and registers them on the ReactorDispatchInterceptorRegistry. The reactor gateways themselves are created by ReactorConfigurationDefaults, which is registered as a ConfigurationEnhancer via the service loader.

Since:

5.1.0

Author:

Theo Emanuelsson

See Also:

• ReactorDispatchInterceptorRegistry

Constructor Summary

Constructors

Constructor	Description
ReactorAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
DecoratorDefinition<ReactorDispatchInterceptorRegistry,ReactorDispatchInterceptorRegistry>	reactorDispatchInterceptorEnhancer(Optional<List<ReactorMessageDispatchInterceptor<? super CommandMessage>>> commandInterceptors, Optional<List<ReactorMessageDispatchInterceptor<? super EventMessage>>> eventInterceptors, Optional<List<ReactorMessageDispatchInterceptor<? super QueryMessage>>> queryInterceptors)	Creates a DecoratorDefinition that registers all discovered ReactorMessageDispatchInterceptor beans on the ReactorDispatchInterceptorRegistry.

Methods inherited from class java.lang.Object

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

Constructor Details

ReactorAutoConfiguration

public ReactorAutoConfiguration()

Method Details

reactorDispatchInterceptorEnhancer

@Bean
@ConditionalOnBean(ReactorMessageDispatchInterceptor.class)
public DecoratorDefinition<ReactorDispatchInterceptorRegistry,ReactorDispatchInterceptorRegistry> reactorDispatchInterceptorEnhancer(Optional<List<ReactorMessageDispatchInterceptor<? super CommandMessage>>> commandInterceptors,
 Optional<List<ReactorMessageDispatchInterceptor<? super EventMessage>>> eventInterceptors,
 Optional<List<ReactorMessageDispatchInterceptor<? super QueryMessage>>> queryInterceptors)

Creates a DecoratorDefinition that registers all discovered ReactorMessageDispatchInterceptor beans on the ReactorDispatchInterceptorRegistry.

Parameters:

commandInterceptors - CommandMessage-specific reactor dispatch interceptors

eventInterceptors - EventMessage-specific reactor dispatch interceptors

queryInterceptors - QueryMessage-specific reactor dispatch interceptors

Returns:

a decorator definition that registers the discovered interceptors