public interface EventProcessor
Modifier and Type | Method and Description |
---|---|
String |
getName()
Returns the name of this event processor.
|
Registration |
registerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> interceptor)
Registers the given
interceptor to this event processor. |
void |
shutDown()
Stop processing events.
|
void |
start()
Start processing events.
|
String getName()
Registration registerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> interceptor)
interceptor
to this event processor. The interceptor
will
receive each event message that is about to be published but before it has reached its event handlers.
Interceptors are free to modify the event message or stop publication altogether. In
addition, interceptors are able to interact with the UnitOfWork
that is created to process the message.
For example, if a CorrelationDataInterceptor
is registered,
each command or event message triggered in response to an intercepted event will get correlation metadata
from the intercepted event.interceptor
- The interceptor to register.interceptor
. When unregistered the interceptor
will
no longer receive events from this event processor.void start()
void shutDown()
Copyright © 2010–2017. All rights reserved.