public interface MessageMonitor<T extends Message<?>>
Modifier and Type | Interface and Description |
---|---|
static interface |
MessageMonitor.MonitorCallback
An interface to let the message processor inform the message monitor of the result
of processing the message
|
Modifier and Type | Method and Description |
---|---|
MessageMonitor.MonitorCallback |
onMessageIngested(T message)
Takes a message and returns a callback that should be used
to inform the message monitor about the result of processing the message
|
default Map<? super T,MessageMonitor.MonitorCallback> |
onMessagesIngested(Collection<? extends T> messages)
Takes a collection of messages and returns a map containing events along with their callbacks
|
MessageMonitor.MonitorCallback onMessageIngested(T message)
message
- the message to monitordefault Map<? super T,MessageMonitor.MonitorCallback> onMessagesIngested(Collection<? extends T> messages)
messages
- to monitorCopyright © 2010–2020. All rights reserved.