Package org.axonframework.extension.reactor.messaging.core.interception

Interface ReactorDispatchInterceptorRegistry

All Superinterfaces:

DescribableComponent

All Known Implementing Classes:

DefaultReactorDispatchInterceptorRegistry

@Internal
public interface ReactorDispatchInterceptorRegistry
extends DescribableComponent

A registry of ReactorMessageDispatchInterceptors for the Reactor extension.

Provides operations to register generic Message, CommandMessage-specific, EventMessage-specific, and QueryMessage-specific ReactorMessageDispatchInterceptors. Registered interceptors can be retrieved through commandInterceptors(Configuration, Class, String), eventInterceptors(Configuration, Class, String), and queryInterceptors(Configuration, Class, String).

Generic Message interceptors registered via registerInterceptor(ComponentBuilder) or registerInterceptor(ReactorDispatchInterceptorFactory) are automatically applied to all message types.

This registry follows the same pattern as DispatchInterceptorRegistry but is specific to reactor-based interceptors.

Since:

5.1.0

Author:

Theo Emanuelsson

See Also:

• ReactorMessageDispatchInterceptor
• ReactorDispatchInterceptorFactory

Method Summary

Modifier and Type	Method	Description
List<ReactorMessageDispatchInterceptor<? super CommandMessage>>	commandInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)	Returns the list of ReactorMessageDispatchInterceptors registered for CommandMessages for a specific componentType and componentName.
List<ReactorMessageDispatchInterceptor<? super EventMessage>>	eventInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)	Returns the list of ReactorMessageDispatchInterceptors registered for EventMessages for a specific componentType and componentName.
List<ReactorMessageDispatchInterceptor<? super QueryMessage>>	queryInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)	Returns the list of ReactorMessageDispatchInterceptors registered for QueryMessages for a specific componentType and componentName.
ReactorDispatchInterceptorRegistry	registerCommandInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<? super CommandMessage>> interceptorBuilder)	Registers the given interceptorBuilder for a CommandMessage-specific ReactorMessageDispatchInterceptor.
ReactorDispatchInterceptorRegistry	registerCommandInterceptor(ReactorDispatchInterceptorFactory<? super CommandMessage> interceptorFactory)	Registers the given component-aware interceptorFactory for a CommandMessage-specific ReactorMessageDispatchInterceptor.
ReactorDispatchInterceptorRegistry	registerEventInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<? super EventMessage>> interceptorBuilder)	Registers the given interceptorBuilder for an EventMessage-specific ReactorMessageDispatchInterceptor.
ReactorDispatchInterceptorRegistry	registerEventInterceptor(ReactorDispatchInterceptorFactory<? super EventMessage> interceptorFactory)	Registers the given component-aware interceptorFactory for an EventMessage-specific ReactorMessageDispatchInterceptor.
ReactorDispatchInterceptorRegistry	registerInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<Message>> interceptorBuilder)	Registers the given interceptorBuilder for a generic Message ReactorMessageDispatchInterceptor.
ReactorDispatchInterceptorRegistry	registerInterceptor(ReactorDispatchInterceptorFactory<Message> interceptorFactory)	Registers the given component-aware interceptorFactory for a generic Message ReactorMessageDispatchInterceptor.
ReactorDispatchInterceptorRegistry	registerQueryInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder)	Registers the given interceptorBuilder for a QueryMessage-specific ReactorMessageDispatchInterceptor.
ReactorDispatchInterceptorRegistry	registerQueryInterceptor(ReactorDispatchInterceptorFactory<? super QueryMessage> interceptorFactory)	Registers the given component-aware interceptorFactory for a QueryMessage-specific ReactorMessageDispatchInterceptor.

Methods inherited from interface org.axonframework.common.infra.DescribableComponent

describeTo

Method Details

registerInterceptor

ReactorDispatchInterceptorRegistry registerInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<Message>> interceptorBuilder)

Registers the given interceptorBuilder for a generic Message ReactorMessageDispatchInterceptor.

Registering an interceptor per a ComponentBuilder ensures the interceptor is only built once.

Parameters:

interceptorBuilder - the generic Message ReactorMessageDispatchInterceptor builder to register

Returns:

this registry, for fluent interfacing

registerInterceptor

ReactorDispatchInterceptorRegistry registerInterceptor(ReactorDispatchInterceptorFactory<Message> interceptorFactory)

Registers the given component-aware interceptorFactory for a generic Message ReactorMessageDispatchInterceptor.

The factory will receive the component type and name when the interceptor is retrieved allowing for component-specific customization of the interceptor. Registering an interceptor per a ReactorDispatchInterceptorFactory enforces construction of the interceptor for every invocation of the factory, ensuring uniqueness per given type and name. If the interceptor will be identical regardless of the given type or name, please use registerInterceptor(ComponentBuilder) instead.

Parameters:

interceptorFactory - the generic Message ReactorMessageDispatchInterceptor factory to register

Returns:

this registry, for fluent interfacing

registerCommandInterceptor

ReactorDispatchInterceptorRegistry registerCommandInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<? super CommandMessage>> interceptorBuilder)

Registers the given interceptorBuilder for a CommandMessage-specific ReactorMessageDispatchInterceptor.

Registering an interceptor per a ComponentBuilder ensures the interceptor is only built once.

Parameters:

interceptorBuilder - the CommandMessage-specific ReactorMessageDispatchInterceptor builder to register

Returns:

this registry, for fluent interfacing

registerCommandInterceptor

ReactorDispatchInterceptorRegistry registerCommandInterceptor(ReactorDispatchInterceptorFactory<? super CommandMessage> interceptorFactory)

Registers the given component-aware interceptorFactory for a CommandMessage-specific ReactorMessageDispatchInterceptor.

The factory will receive the component type and name when the interceptor is retrieved allowing for component-specific customization of the interceptor. Registering an interceptor per a ReactorDispatchInterceptorFactory enforces construction of the interceptor for every invocation of the factory, ensuring uniqueness per given type and name. If the interceptor will be identical regardless of the given type or name, please use registerCommandInterceptor(ComponentBuilder) instead.

Parameters:

interceptorFactory - the CommandMessage-specific ReactorMessageDispatchInterceptor factory to register

Returns:

this registry, for fluent interfacing

registerEventInterceptor

ReactorDispatchInterceptorRegistry registerEventInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<? super EventMessage>> interceptorBuilder)

Registers the given interceptorBuilder for an EventMessage-specific ReactorMessageDispatchInterceptor.

Registering an interceptor per a ComponentBuilder ensures the interceptor is only built once.

Parameters:

interceptorBuilder - the EventMessage-specific ReactorMessageDispatchInterceptor builder to register

Returns:

this registry, for fluent interfacing

registerEventInterceptor

ReactorDispatchInterceptorRegistry registerEventInterceptor(ReactorDispatchInterceptorFactory<? super EventMessage> interceptorFactory)

Registers the given component-aware interceptorFactory for an EventMessage-specific ReactorMessageDispatchInterceptor.

The factory will receive the component type and name when the interceptor is retrieved allowing for component-specific customization of the interceptor. Registering an interceptor per a ReactorDispatchInterceptorFactory enforces construction of the interceptor for every invocation of the factory, ensuring uniqueness per given type and name. If the interceptor will be identical regardless of the given type or name, please use registerEventInterceptor(ComponentBuilder) instead.

Parameters:

interceptorFactory - the EventMessage-specific ReactorMessageDispatchInterceptor factory to register

Returns:

this registry, for fluent interfacing

registerQueryInterceptor

ReactorDispatchInterceptorRegistry registerQueryInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder)

Registers the given interceptorBuilder for a QueryMessage-specific ReactorMessageDispatchInterceptor.

Registering an interceptor per a ComponentBuilder ensures the interceptor is only built once.

Parameters:

interceptorBuilder - the QueryMessage-specific ReactorMessageDispatchInterceptor builder to register

Returns:

this registry, for fluent interfacing

registerQueryInterceptor

ReactorDispatchInterceptorRegistry registerQueryInterceptor(ReactorDispatchInterceptorFactory<? super QueryMessage> interceptorFactory)

Registers the given component-aware interceptorFactory for a QueryMessage-specific ReactorMessageDispatchInterceptor.

The factory will receive the component type and name when the interceptor is retrieved allowing for component-specific customization of the interceptor. Registering an interceptor per a ReactorDispatchInterceptorFactory enforces construction of the interceptor for every invocation of the factory, ensuring uniqueness per given type and name. If the interceptor will be identical regardless of the given type or name, please use registerQueryInterceptor(ComponentBuilder) instead.

Parameters:

interceptorFactory - the QueryMessage-specific ReactorMessageDispatchInterceptor factory to register

Returns:

this registry, for fluent interfacing

commandInterceptors

List<ReactorMessageDispatchInterceptor<? super CommandMessage>> commandInterceptors(Configuration config,
 Class<?> componentType,
 @Nullable String componentName)

Returns the list of ReactorMessageDispatchInterceptors registered for CommandMessages for a specific componentType and componentName.

Parameters:

config - the configuration to build all CommandMessage-specific ReactorMessageDispatchInterceptors with

componentType - the type of the component being intercepted

componentName - the name of the component being intercepted

Returns:

the list of command dispatch interceptors

eventInterceptors

List<ReactorMessageDispatchInterceptor<? super EventMessage>> eventInterceptors(Configuration config,
 Class<?> componentType,
 @Nullable String componentName)

Returns the list of ReactorMessageDispatchInterceptors registered for EventMessages for a specific componentType and componentName.

Parameters:

config - the configuration to build all EventMessage-specific ReactorMessageDispatchInterceptors with

componentType - the type of the component being intercepted

componentName - the name of the component being intercepted

Returns:

the list of event dispatch interceptors

queryInterceptors

List<ReactorMessageDispatchInterceptor<? super QueryMessage>> queryInterceptors(Configuration config,
 Class<?> componentType,
 @Nullable String componentName)

Returns the list of ReactorMessageDispatchInterceptors registered for QueryMessages for a specific componentType and componentName.

Parameters:

config - the configuration to build all QueryMessage-specific ReactorMessageDispatchInterceptors with

componentType - the type of the component being intercepted

componentName - the name of the component being intercepted

Returns:

the list of query dispatch interceptors