public interface EventProcessor extends MessageHandlerInterceptorSupport<EventMessage<?>>
Modifier and Type | Method and Description |
---|---|
List<MessageHandlerInterceptor<? super EventMessage<?>>> |
getHandlerInterceptors()
Return the list of already registered
MessageHandlerInterceptor s for this event processor. |
String |
getName()
Returns the name of this event processor.
|
boolean |
isError()
Indicates whether the processor has been shut down due to an error.
|
boolean |
isRunning()
Indicates whether this processor is currently running (i.e.
|
void |
shutDown()
Stops processing events.
|
default CompletableFuture<Void> |
shutdownAsync()
Initiates a shutdown, providing a
CompletableFuture that completes when the shutdown process is
finished. |
void |
start()
Start processing events.
|
registerHandlerInterceptor
String getName()
List<MessageHandlerInterceptor<? super EventMessage<?>>> getHandlerInterceptors()
MessageHandlerInterceptor
s for this event processor.
To register a new interceptor use MessageHandlerInterceptorSupport.registerHandlerInterceptor(MessageHandlerInterceptor)
void start()
void shutDown()
boolean isRunning()
true
when running, otherwise false
boolean isError()
Note that this method returns false
when the processor was stopped using shutDown()
.
true
when paused due to an error, otherwise false
default CompletableFuture<Void> shutdownAsync()
CompletableFuture
that completes when the shutdown process is
finished.Copyright © 2010–2023. All rights reserved.