public interface EventProcessingConfiguration
Modifier and Type | Method and Description |
---|---|
ErrorHandler |
errorHandler(String processingGroup)
Returns the
ErrorHandler tied to the given processingGroup . |
default <T extends EventProcessor> |
eventProcessor(String name)
Obtains an
EventProcessor through the given name . |
default <T extends EventProcessor> |
eventProcessor(String name,
Class<T> expectedType)
|
<T extends EventProcessor> |
eventProcessorByProcessingGroup(String processingGroup)
Obtains an
EventProcessor by it's processingGroup . |
default <T extends EventProcessor> |
eventProcessorByProcessingGroup(String processingGroup,
Class<T> expectedType)
|
Map<String,EventProcessor> |
eventProcessors()
Obtains all registered
EventProcessor s. |
List<MessageHandlerInterceptor<? super EventMessage<?>>> |
interceptorsFor(String processorName)
|
ListenerInvocationErrorHandler |
listenerInvocationErrorHandler(String processingGroup)
Returns the
ListenerInvocationErrorHandler tied to the given processingGroup . |
MessageMonitor<? super Message<?>> |
messageMonitor(Class<?> componentType,
String componentName)
Returns the
MessageMonitor set to the given componentType and componentName registered
within this configuration. |
RollbackConfiguration |
rollbackConfiguration(String processingGroup)
Returns the
RollbackConfiguration tied to the given processingGroup . |
default <T> SagaConfiguration<T> |
sagaConfiguration(Class<T> sagaType)
Returns the
SagaConfiguration for the given sagaType . |
List<SagaConfiguration<?>> |
sagaConfigurations()
Returns a
List of SagaConfiguration s registered within this configuration. |
default <T extends EventProcessor> |
sagaEventProcessor(Class<?> sagaType)
Obtains an Saga
EventProcessor implementation for the given sagaType . |
String |
sagaProcessingGroup(Class<?> sagaType)
Gets the processing group for given
sagaType . |
SagaStore |
sagaStore()
Returns a
SagaStore registered within this configuration. |
SequencingPolicy<? super EventMessage<?>> |
sequencingPolicy(String processingGroup)
Returns the
SequencingPolicy tied to the given processingGroup . |
TokenStore |
tokenStore(String processorName)
Returns the
TokenStore tied to the given processingGroup . |
TransactionManager |
transactionManager(String processingGroup)
Returns the
TransactionManager tied to the given processingGroup . |
default <T extends EventProcessor> Optional<T> eventProcessor(String name)
EventProcessor
through the given name
.T
- the type of the expected EventProcessor
name
- a String
specifying the name of an EventProcessor
Optional
specifying whether an EventProcessor
with the given name
existsdefault <T extends EventProcessor> Optional<T> sagaEventProcessor(Class<?> sagaType)
EventProcessor
implementation for the given sagaType
.T
- the type of the expected EventProcessor
sagaType
- the type of Saga for which to get the Event ProcessorOptional
specifying whether an EventProcessor
for the given SagaConfiguration
existsdefault <T extends EventProcessor> Optional<T> eventProcessor(String name, Class<T> expectedType)
T
- the type of the expected EventProcessor
name
- a String
specifying the name of the EventProcessor
to returnexpectedType
- the type of the EventProcessor
to returnOptional
referencing the EventProcessor
, if present and of expected type<T extends EventProcessor> Optional<T> eventProcessorByProcessingGroup(String processingGroup)
EventProcessor
by it's processingGroup
.T
- the type of the expected EventProcessor
processingGroup
- a String
specifying the processing group of an EventProcessor
Optional
referencing the EventProcessor
default <T extends EventProcessor> Optional<T> eventProcessorByProcessingGroup(String processingGroup, Class<T> expectedType)
T
- the type of the expected EventProcessor
processingGroup
- a String
specifying the processing group of an EventProcessor
expectedType
- the type of the EventProcessor
to returnOptional
referencing the EventProcessor
, if present and of expected typeMap<String,EventProcessor> eventProcessors()
EventProcessor
s.Map
of registered EventProcessor
s within this configuration with the processor names as
keysString sagaProcessingGroup(Class<?> sagaType)
sagaType
.sagaType
- the type of SagaList<MessageHandlerInterceptor<? super EventMessage<?>>> interceptorsFor(String processorName)
processorName
- a String
specifying a processing groupList
of MessageHandlerInterceptor
s for a processor with given processorName
ListenerInvocationErrorHandler listenerInvocationErrorHandler(String processingGroup)
ListenerInvocationErrorHandler
tied to the given processingGroup
.processingGroup
- a String
specifying a processing groupListenerInvocationErrorHandler
belonging to the given processingGroup
SequencingPolicy<? super EventMessage<?>> sequencingPolicy(String processingGroup)
SequencingPolicy
tied to the given processingGroup
.processingGroup
- a String
specifying a processing groupSequencingPolicy
belonging to the given processingGroup
RollbackConfiguration rollbackConfiguration(String processingGroup)
RollbackConfiguration
tied to the given processingGroup
.processingGroup
- a String
specifying a processing groupRollbackConfiguration
belonging to the given processingGroup
ErrorHandler errorHandler(String processingGroup)
ErrorHandler
tied to the given processingGroup
.processingGroup
- a String
specifying a processing groupErrorHandler
belonging to the given processingGroup
SagaStore sagaStore()
SagaStore
registered within this configuration.SagaStore
registered within this configurationList<SagaConfiguration<?>> sagaConfigurations()
List
of SagaConfiguration
s registered within this configuration.List
of SagaConfiguration
s registered within this configurationdefault <T> SagaConfiguration<T> sagaConfiguration(Class<T> sagaType)
SagaConfiguration
for the given sagaType
. If no configuration has been provided for
a Saga of this type, null
is returned.T
- the type of SagasagaType
- the type of Saga to return the configuration for.null
if not foundMessageMonitor<? super Message<?>> messageMonitor(Class<?> componentType, String componentName)
MessageMonitor
set to the given componentType
and componentName
registered
within this configuration.componentType
- a Class
type of component to be monitoredcomponentName
- a String
specifying the name of the component to be monitoredMessageMonitor
registered to the given componentType
and componentName
TokenStore tokenStore(String processorName)
TokenStore
tied to the given processingGroup
.processorName
- a String
specifying a event processorTokenStore
belonging to the given processingGroup
TransactionManager transactionManager(String processingGroup)
TransactionManager
tied to the given processingGroup
.processingGroup
- a String
specifying a processing groupTransactionManager
belonging to the given processingGroup
Copyright © 2010–2019. All rights reserved.