Package | Description |
---|---|
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.metrics | |
org.axonframework.monitoring |
Constructor and Description |
---|
MonitorAwareCallback(CommandCallback<C,R> delegate,
MessageMonitor.MonitorCallback messageMonitorCallback)
Initialize a callback wrapped around the
delegate which will notify a Message Monitor for the given messageMonitorCallback . |
Modifier and Type | Method and Description |
---|---|
MessageMonitor.MonitorCallback |
EventProcessorLatencyMonitor.onMessageIngested(EventMessage<?> message) |
MessageMonitor.MonitorCallback |
PayloadTypeMessageMonitorWrapper.onMessageIngested(Message<?> message) |
MessageMonitor.MonitorCallback |
MessageTimerMonitor.onMessageIngested(Message<?> message) |
MessageMonitor.MonitorCallback |
MessageCountingMonitor.onMessageIngested(Message<?> message) |
MessageMonitor.MonitorCallback |
CapacityMonitor.onMessageIngested(Message<?> message) |
Modifier and Type | Class and Description |
---|---|
class |
NoOpMessageMonitorCallback
A NoOp MessageMonitor callback
|
Modifier and Type | Method and Description |
---|---|
MessageMonitor.MonitorCallback |
NoOpMessageMonitor.onMessageIngested(Message<?> message) |
MessageMonitor.MonitorCallback |
MultiMessageMonitor.onMessageIngested(T message)
Calls the message monitors with the given message and returns a callback
that will trigger all the message monitor callbacks
|
MessageMonitor.MonitorCallback |
MessageMonitor.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
|
Modifier and Type | Method and Description |
---|---|
default Map<? super T,MessageMonitor.MonitorCallback> |
MessageMonitor.onMessagesIngested(Collection<? extends T> messages)
Takes a collection of messages and returns a map containing events along with their callbacks
|
Copyright © 2010–2018. All rights reserved.