Uses of Interface
org.axonframework.monitoring.MessageMonitor

Packages that use MessageMonitor

Package	Description
org.axonframework.commandhandling	Classes that implement the concept of command handling using explicit command objects.
org.axonframework.commandhandling.disruptor
org.axonframework.commandhandling.distributed
org.axonframework.config
org.axonframework.eventhandling	Classes related to event handling and dispatching, such as Event Listeners and the Event Bus.
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.kafka.eventhandling.producer
org.axonframework.metrics
org.axonframework.monitoring
org.axonframework.queryhandling
org.axonframework.spring.config

Uses of MessageMonitor in org.axonframework.commandhandling

Constructors in org.axonframework.commandhandling with parameters of type MessageMonitor

Constructor and Description
AsynchronousCommandBus(Executor executor, TransactionManager transactionManager, MessageMonitor<? super CommandMessage<?>> messageMonitor) Initialize the AsynchronousCommandBus using the given executor, transactionManager and messageMonitor.
SimpleCommandBus(TransactionManager transactionManager, MessageMonitor<? super CommandMessage<?>> messageMonitor) Initializes the SimpleCommandBus with the given transactionManager and messageMonitor

Uses of MessageMonitor in org.axonframework.commandhandling.disruptor

Methods in org.axonframework.commandhandling.disruptor that return MessageMonitor

Modifier and Type	Method and Description
MessageMonitor<? super CommandMessage<?>>	DisruptorConfiguration.getMessageMonitor() Returns the message monitor to use.

Methods in org.axonframework.commandhandling.disruptor with parameters of type MessageMonitor

Modifier and Type	Method and Description
DisruptorConfiguration	DisruptorConfiguration.setMessageMonitor(MessageMonitor<? super CommandMessage<?>> messageMonitor) Sets the message monitor to use.

Uses of MessageMonitor in org.axonframework.commandhandling.distributed

Constructors in org.axonframework.commandhandling.distributed with parameters of type MessageMonitor

Constructor and Description
DistributedCommandBus(CommandRouter commandRouter, CommandBusConnector connector, MessageMonitor<? super CommandMessage<?>> messageMonitor) Initializes the command bus with the given commandRouter, connector and messageMonitor.

Uses of MessageMonitor in org.axonframework.config

Methods in org.axonframework.config that return MessageMonitor

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.
<M extends Message<?>> MessageMonitor<? super M>	Configuration.messageMonitor(Class<?> componentType, String componentName) Returns the message monitor configured for a component of given componentType and componentName.

Method parameters in org.axonframework.config with type arguments of type MessageMonitor

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.
SagaConfiguration<S>	SagaConfiguration.configureMessageMonitor(Function<Configuration,MessageMonitor<? super EventMessage<?>>> messageMonitor) Deprecated. use EventProcessingConfiguration.configureMessageMonitor(String, Function) instead
EventProcessingConfiguration	EventProcessingConfiguration.configureMessageMonitor(String name, Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder) Configures the builder function to create the Message Monitor for the EventProcessor of the given name.
EventHandlingConfiguration	EventHandlingConfiguration.configureMessageMonitor(String name, Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder) Deprecated. use EventProcessingConfiguration.configureMessageMonitor(String, Function) instead

Uses of MessageMonitor in org.axonframework.eventhandling

Constructors in org.axonframework.eventhandling with parameters of type MessageMonitor

Constructor and Description
AbstractEventBus(MessageMonitor<? super EventMessage<?>> messageMonitor) Initializes an event bus.
AbstractEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, RollbackConfiguration rollbackConfiguration, ErrorHandler errorHandler, MessageMonitor<? super EventMessage<?>> messageMonitor) Initializes an event processor with given name.
SimpleEventBus(int queueCapacity, MessageMonitor<? super EventMessage<?>> messageMonitor) Initializes an event bus.
SubscribingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, RollbackConfiguration rollbackConfiguration, SubscribableMessageSource<? extends EventMessage<?>> messageSource, EventProcessingStrategy processingStrategy, ErrorHandler errorHandler, MessageMonitor<? super EventMessage<?>> messageMonitor) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.
SubscribingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, SubscribableMessageSource<? extends EventMessage<?>> messageSource, EventProcessingStrategy processingStrategy, ErrorHandler errorHandler, MessageMonitor<? super EventMessage<?>> messageMonitor) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.
TrackingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, StreamableMessageSource<TrackedEventMessage<?>> messageSource, TokenStore tokenStore, TransactionManager transactionManager, MessageMonitor<? super EventMessage<?>> messageMonitor) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.
TrackingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, StreamableMessageSource<TrackedEventMessage<?>> messageSource, TokenStore tokenStore, TransactionManager transactionManager, MessageMonitor<? super EventMessage<?>> messageMonitor, RollbackConfiguration rollbackConfiguration, ErrorHandler errorHandler, TrackingEventProcessorConfiguration config) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.

Uses of MessageMonitor in org.axonframework.eventsourcing.eventstore

Constructors in org.axonframework.eventsourcing.eventstore with parameters of type MessageMonitor

Constructor and Description
AbstractEventStore(EventStorageEngine storageEngine, MessageMonitor<? super EventMessage<?>> messageMonitor) Initializes an event store with given storageEngine and messageMonitor.
EmbeddedEventStore(EventStorageEngine storageEngine, MessageMonitor<? super EventMessage<?>> monitor) Initializes an EmbeddedEventStore with given storageEngine and monitor and default settings.
EmbeddedEventStore(EventStorageEngine storageEngine, MessageMonitor<? super EventMessage<?>> monitor, int cachedEvents, long fetchDelay, long cleanupDelay, TimeUnit timeUnit) Initializes an EmbeddedEventStore with given storageEngine and monitor and custom settings.

Uses of MessageMonitor in org.axonframework.kafka.eventhandling.producer

Methods in org.axonframework.kafka.eventhandling.producer that return MessageMonitor

Modifier and Type	Method and Description
MessageMonitor<? super EventMessage<?>>	KafkaPublisherConfiguration.getMessageMonitor()

Methods in org.axonframework.kafka.eventhandling.producer with parameters of type MessageMonitor

Modifier and Type	Method and Description
KafkaPublisherConfiguration.Builder<K,V>	KafkaPublisherConfiguration.Builder.withMessageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) Configure MessageMonitor.

Uses of MessageMonitor in org.axonframework.metrics

Classes in org.axonframework.metrics with type parameters of type 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.

Classes in org.axonframework.metrics that implement MessageMonitor

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 Measures the difference in message timestamps between the last ingested and the last processed message.
class	MessageCountingMonitor Counts the number of ingested, successful, failed and processed messages
class	MessageTimerMonitor Times allTimer messages, successful and failed messages
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.

Methods in org.axonframework.metrics that return MessageMonitor

Modifier and Type	Method and Description
MessageMonitor<? super CommandMessage<?>>	GlobalMetricRegistry.registerCommandBus(String name) Registers new metrics to the registry to monitor a CommandBus.
MessageMonitor<? extends Message<?>>	GlobalMetricRegistry.registerComponent(Class<?> componentType, String componentName) Registers new metrics to the registry to monitor a component of given type.
MessageMonitor<? super EventMessage<?>>	GlobalMetricRegistry.registerEventBus(String name) 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 name) Registers new metrics to the registry to monitor a CommandBus.

Uses of MessageMonitor in org.axonframework.monitoring

Classes in org.axonframework.monitoring that implement MessageMonitor

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

Constructors in org.axonframework.monitoring with parameters of type MessageMonitor

Constructor and Description
MultiMessageMonitor(MessageMonitor<? super T>... messageMonitors) Initialize a message monitor with the given messageMonitors

Constructor parameters in org.axonframework.monitoring with type arguments of type MessageMonitor

Constructor and Description
MultiMessageMonitor(List<MessageMonitor<? super T>> messageMonitors) Initialize a message monitor with the given list of messageMonitors

Uses of MessageMonitor in org.axonframework.queryhandling

Constructors in org.axonframework.queryhandling with parameters of type MessageMonitor

Constructor and Description
SimpleQueryBus(MessageMonitor<? super QueryMessage<?,?>> messageMonitor, MessageMonitor<? super SubscriptionQueryUpdateMessage<?>> updateMessageMonitor, TransactionManager transactionManager, QueryInvocationErrorHandler errorHandler) Initialize the query bus with the given messageMonitor, updateMessageMonitor, transactionManager and given errorHandler.
SimpleQueryBus(MessageMonitor<? super QueryMessage<?,?>> messageMonitor, MessageMonitor<? super SubscriptionQueryUpdateMessage<?>> updateMessageMonitor, TransactionManager transactionManager, QueryInvocationErrorHandler errorHandler) Initialize the query bus with the given messageMonitor, updateMessageMonitor, transactionManager and given errorHandler.
SimpleQueryBus(MessageMonitor<? super QueryMessage<?,?>> messageMonitor, TransactionManager transactionManager, QueryInvocationErrorHandler errorHandler) Initialize the query bus with the given messageMonitor and given errorHandler.

Uses of MessageMonitor in org.axonframework.spring.config

Methods in org.axonframework.spring.config that return MessageMonitor

Modifier and Type	Method and Description
<M extends Message<?>> MessageMonitor<? super M>	AxonConfiguration.messageMonitor(Class<?> componentType, String componentName)