Package | Description |
---|---|
org.axonframework.axonserver.connector.event.axon | |
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.commandhandling.distributed | |
org.axonframework.config | |
org.axonframework.disruptor.commandhandling | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.eventhandling.pooled | |
org.axonframework.eventsourcing.eventstore |
Definitions and implementations of the Event store, the mechanism that can load event streams and append events to
them.
|
org.axonframework.eventsourcing.eventstore.legacyjpa | |
org.axonframework.metrics | |
org.axonframework.micrometer | |
org.axonframework.monitoring | |
org.axonframework.queryhandling | |
org.axonframework.spring.config |
Modifier and Type | Method and Description |
---|---|
AxonServerEventStoreFactory.Builder |
AxonServerEventStoreFactory.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)
Sets the
MessageMonitor to monitor ingested EventMessages . |
AxonServerEventStore.Builder |
AxonServerEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) |
Modifier and Type | Method and Description |
---|---|
SimpleCommandBus.Builder |
SimpleCommandBus.Builder.messageMonitor(MessageMonitor<? super CommandMessage<?>> messageMonitor)
Sets the
MessageMonitor of generic type CommandMessage used the to monitor the command bus. |
AsynchronousCommandBus.Builder |
AsynchronousCommandBus.Builder.messageMonitor(MessageMonitor<? super CommandMessage<?>> messageMonitor) |
Modifier and Type | Method and Description |
---|---|
DistributedCommandBus.Builder |
DistributedCommandBus.Builder.messageMonitor(MessageMonitor<? super CommandMessage<?>> messageMonitor)
Sets the
MessageMonitor for generic types implementing CommandMessage , which is used to
monitor incoming messages and their execution result. |
Modifier and Type | Method and Description |
---|---|
MessageMonitor<Message<?>> |
MessageMonitorFactory.create(Configuration configuration,
Class<?> componentType,
String componentName)
Function to create a Message Monitor based on the given configuration, component type and component name.
|
MessageMonitor<? super Message<?>> |
EventProcessingModule.messageMonitor(Class<?> componentType,
String eventProcessorName) |
MessageMonitor<? super Message<?>> |
EventProcessingConfiguration.messageMonitor(Class<?> componentType,
String componentName)
Returns the
MessageMonitor set to the given componentType and componentName registered
within this configuration. |
<M extends Message<?>> |
Configuration.messageMonitor(Class<?> componentType,
String componentName)
Returns the message monitor configured for a component of given
componentType and componentName . |
Modifier and Type | Method and Description |
---|---|
default Configurer |
Configurer.configureMessageMonitor(Class<?> componentType,
Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)
Configures the builder function to create the Message Monitor for the Message processing components in this
configuration that match the given componentType, unless more specific configuration based on both type and name
is available.
|
default Configurer |
Configurer.configureMessageMonitor(Class<?> componentType,
String componentName,
Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)
Configures the builder function to create the Message Monitor for the Message processing components in this
configuration that match the given class and name.
|
Configurer |
DefaultConfigurer.configureMessageMonitor(Function<Configuration,BiFunction<Class<?>,String,MessageMonitor<Message<?>>>> builder) |
Configurer |
Configurer.configureMessageMonitor(Function<Configuration,BiFunction<Class<?>,String,MessageMonitor<Message<?>>>> messageMonitorFactoryBuilder)
Configures the Message Monitor to use for the Message processing components in this configuration, unless more
specific configuration based on the component's type, or type and name is available.
|
default EventProcessingConfigurer |
EventProcessingConfigurer.registerMessageMonitor(String eventProcessorName,
Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)
|
Modifier and Type | Method and Description |
---|---|
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.messageMonitor(MessageMonitor<? super CommandMessage<?>> messageMonitor)
Sets the
MessageMonitor of generic type CommandMessage used the to monitor the command bus. |
Modifier and Type | Method and Description |
---|---|
TrackingEventProcessor.Builder |
TrackingEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) |
SubscribingEventProcessor.Builder |
SubscribingEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) |
SimpleEventBus.Builder |
SimpleEventBus.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) |
AbstractEventProcessor.Builder |
AbstractEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)
Sets the
MessageMonitor to monitor EventMessage s before and after they're processed. |
AbstractEventBus.Builder |
AbstractEventBus.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)
Sets the
MessageMonitor to monitor ingested EventMessage s. |
Modifier and Type | Method and Description |
---|---|
PooledStreamingEventProcessor.Builder |
PooledStreamingEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) |
Modifier and Type | Method and Description |
---|---|
EmbeddedEventStore.Builder |
EmbeddedEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) |
AbstractEventStore.Builder |
AbstractEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) |
Modifier and Type | Method and Description |
---|---|
EmbeddedEventStore.Builder |
EmbeddedEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) |
Modifier and Type | Class and Description |
---|---|
class |
PayloadTypeMessageMonitorWrapper<T extends MessageMonitor<Message<?>> & com.codahale.metrics.MetricSet>
A
MessageMonitor implementation which creates a new MessageMonitor for every Message payload type
ingested by it. |
Modifier and Type | Class and Description |
---|---|
class |
CapacityMonitor
Calculates capacity by tracking, within the configured time window, the average message processing time
and multiplying that by the amount of messages processed.
|
class |
EventProcessorLatencyMonitor
A
MessageMonitor implementation dedicated to EventMessages . |
class |
MessageCountingMonitor
Counts the number of ingested, successful, failed and processed messages
|
class |
MessageTimerMonitor
A
MessageMonitor which creates Timer instances for the overall, success, failure and ignored time an
ingested Message takes. |
class |
PayloadTypeMessageMonitorWrapper<T extends MessageMonitor<Message<?>> & com.codahale.metrics.MetricSet>
A
MessageMonitor implementation which creates a new MessageMonitor for every Message payload type
ingested by it. |
Modifier and Type | Method and Description |
---|---|
MessageMonitor<? super CommandMessage<?>> |
GlobalMetricRegistry.registerCommandBus(String commandBusName)
Registers new metrics to the registry to monitor a
CommandBus . |
MessageMonitor<? extends Message<?>> |
GlobalMetricRegistry.registerComponent(Class<?> componentType,
String componentName)
Registers new metrics to the
MetricRegistry to monitor a component of given componentType . |
MessageMonitor<? super EventMessage<?>> |
GlobalMetricRegistry.registerEventBus(String eventBusName)
Registers new metrics to the registry to monitor an
EventBus . |
MessageMonitor<? super EventMessage<?>> |
GlobalMetricRegistry.registerEventProcessor(String eventProcessorName)
Registers new metrics to the registry to monitor an
EventProcessor . |
MessageMonitor<? super QueryMessage<?,?>> |
GlobalMetricRegistry.registerQueryBus(String queryBusName)
Registers new metrics to the registry to monitor a
QueryBus . |
Modifier and Type | Class and Description |
---|---|
class |
PayloadTypeMessageMonitorWrapper<T extends MessageMonitor<Message<?>>>
Deprecated.
As of release 4.4, replaced by using
Tag s on the monitor implementations.
Use {@link org.axonframework.micrometer.GlobalMetricRegistry#registerWithConfigurerWithDefaultTags(Configurer) to achieve the same behavior as this implementation. |
Modifier and Type | Method and Description |
---|---|
MessageMonitor<? super CommandMessage<?>> |
GlobalMetricRegistry.registerCommandBus(String commandBusName)
Registers new metrics to the registry to monitor a
CommandBus . |
MessageMonitor<? super CommandMessage<?>> |
GlobalMetricRegistry.registerCommandBus(String commandBusName,
Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder)
Registers new metrics to the registry to monitor a
CommandBus using Tag s through the given tagsBuilder . |
MessageMonitor<? extends Message<?>> |
GlobalMetricRegistry.registerComponent(Class<?> componentType,
String componentName)
Registers new metrics to the registry to monitor a component of the given
componentType . |
MessageMonitor<? extends Message<?>> |
GlobalMetricRegistry.registerComponentWithDefaultTags(Class<?> componentType,
String componentName)
Registers new metrics to the registry to monitor a component of the given
componentType . |
MessageMonitor<? super EventMessage<?>> |
GlobalMetricRegistry.registerEventBus(String eventBusName)
Registers new metrics to the registry to monitor an
EventBus . |
MessageMonitor<? super EventMessage<?>> |
GlobalMetricRegistry.registerEventBus(String eventBusName,
Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder)
Registers new metrics to the registry to monitor an
EventBus using Tag s through the given tagsBuilder . |
MessageMonitor<? super EventMessage<?>> |
GlobalMetricRegistry.registerEventProcessor(String eventProcessorName)
Registers new metrics to the registry to monitor an
EventProcessor . |
MessageMonitor<? super EventMessage<?>> |
GlobalMetricRegistry.registerEventProcessor(String eventProcessorName,
Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder)
Deprecated.
Please use the
GlobalMetricRegistry.registerEventProcessor(String, Function, Function) instead, which has
separate tags for the latency metric. |
MessageMonitor<? super EventMessage<?>> |
GlobalMetricRegistry.registerEventProcessor(String eventProcessorName,
Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder,
Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> latencyTagsBuilder)
Registers new metrics to the registry to monitor an
EventProcessor using Tag s through the given
tagsBuilder . |
MessageMonitor<? super QueryMessage<?,?>> |
GlobalMetricRegistry.registerQueryBus(String queryBusName)
Registers new metrics to the registry to monitor a
QueryBus . |
MessageMonitor<? super QueryMessage<?,?>> |
GlobalMetricRegistry.registerQueryBus(String queryBusName,
Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder)
Registers new metrics to the registry to monitor a
QueryBus using Tag s through the given tagsBuilder . |
Modifier and Type | Class and Description |
---|---|
class |
MultiMessageMonitor<T extends Message<?>>
Delegates messages and callbacks to the given list of message monitors
|
class |
NoOpMessageMonitor
A message monitor that returns a NoOp message callback
|
Constructor and Description |
---|
MultiMessageMonitor(MessageMonitor<? super T>... messageMonitors)
Initialize a message monitor with the given
|
Constructor and Description |
---|
MultiMessageMonitor(List<MessageMonitor<? super T>> messageMonitors)
Initialize a message monitor with the given list of
|
Modifier and Type | Method and Description |
---|---|
SimpleQueryBus.Builder |
SimpleQueryBus.Builder.messageMonitor(MessageMonitor<? super QueryMessage<?,?>> messageMonitor)
Sets the
MessageMonitor used to monitor query messages. |
SimpleQueryUpdateEmitter.Builder |
SimpleQueryUpdateEmitter.Builder.updateMessageMonitor(MessageMonitor<? super SubscriptionQueryUpdateMessage<?>> updateMessageMonitor)
Sets the
MessageMonitor used to monitor SubscriptionQueryUpdateMessage s being processed. |
Modifier and Type | Method and Description |
---|---|
<M extends Message<?>> |
AxonConfiguration.messageMonitor(Class<?> componentType,
String componentName)
Deprecated.
|
Copyright © 2010–2024. All rights reserved.