Uses of Interface
org.axonframework.monitoring.MessageMonitor
Packages that use MessageMonitor
Package
Description
Classes that implement the concept of command handling using explicit command objects.
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus.Definitions and implementations of the Event store, the mechanism that can load event streams and append events to
them.
-
Uses of MessageMonitor in org.axonframework.axonserver.connector.event.axon
Methods in org.axonframework.axonserver.connector.event.axon with parameters of type MessageMonitorModifier and TypeMethodDescriptionAxonServerEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) AxonServerEventStoreFactory.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) Sets theMessageMonitorto monitor ingestedEventMessages. -
Uses of MessageMonitor in org.axonframework.commandhandling
Methods in org.axonframework.commandhandling with parameters of type MessageMonitorModifier and TypeMethodDescriptionAsynchronousCommandBus.Builder.messageMonitor(MessageMonitor<? super CommandMessage<?>> messageMonitor) SimpleCommandBus.Builder.messageMonitor(MessageMonitor<? super CommandMessage<?>> messageMonitor) Sets theMessageMonitorof generic typeCommandMessageused the to monitor the command bus. -
Uses of MessageMonitor in org.axonframework.commandhandling.distributed
Methods in org.axonframework.commandhandling.distributed with parameters of type MessageMonitorModifier and TypeMethodDescriptionDistributedCommandBus.Builder.messageMonitor(MessageMonitor<? super CommandMessage<?>> messageMonitor) Sets theMessageMonitorfor generic types implementingCommandMessage, which is used to monitor incoming messages and their execution result. -
Uses of MessageMonitor in org.axonframework.config
Methods in org.axonframework.config that return MessageMonitorModifier and TypeMethodDescriptionMessageMonitorFactory.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 givencomponentTypeandcomponentName.MessageMonitor<? super Message<?>> EventProcessingConfiguration.messageMonitor(Class<?> componentType, String componentName) Returns theMessageMonitorset to the givencomponentTypeandcomponentNameregistered within this configuration.MessageMonitor<? super Message<?>> EventProcessingModule.messageMonitor(Class<?> componentType, String eventProcessorName) Method parameters in org.axonframework.config with type arguments of type MessageMonitorModifier and TypeMethodDescriptiondefault ConfigurerConfigurer.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.default ConfigurerConfigurer.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.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.DefaultConfigurer.configureMessageMonitor(Function<Configuration, BiFunction<Class<?>, String, MessageMonitor<Message<?>>>> builder) default EventProcessingConfigurerEventProcessingConfigurer.registerMessageMonitor(String eventProcessorName, Function<Configuration, MessageMonitor<Message<?>>> messageMonitorBuilder) -
Uses of MessageMonitor in org.axonframework.disruptor.commandhandling
Methods in org.axonframework.disruptor.commandhandling with parameters of type MessageMonitorModifier and TypeMethodDescriptionDisruptorCommandBus.Builder.messageMonitor(MessageMonitor<? super CommandMessage<?>> messageMonitor) Sets theMessageMonitorof generic typeCommandMessageused the to monitor the command bus. -
Uses of MessageMonitor in org.axonframework.eventhandling
Methods in org.axonframework.eventhandling with parameters of type MessageMonitorModifier and TypeMethodDescriptionAbstractEventBus.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) Sets theMessageMonitorto monitor ingestedEventMessages.AbstractEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) Sets theMessageMonitorto monitorEventMessages before and after they're processed.SimpleEventBus.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) SubscribingEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) TrackingEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) -
Uses of MessageMonitor in org.axonframework.eventhandling.pooled
Methods in org.axonframework.eventhandling.pooled with parameters of type MessageMonitorModifier and TypeMethodDescriptionPooledStreamingEventProcessor.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) -
Uses of MessageMonitor in org.axonframework.eventsourcing.eventstore
Methods in org.axonframework.eventsourcing.eventstore with parameters of type MessageMonitorModifier and TypeMethodDescriptionAbstractEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) EmbeddedEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) -
Uses of MessageMonitor in org.axonframework.eventsourcing.eventstore.legacyjpa
Methods in org.axonframework.eventsourcing.eventstore.legacyjpa with parameters of type MessageMonitorModifier and TypeMethodDescriptionEmbeddedEventStore.Builder.messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) -
Uses of MessageMonitor in org.axonframework.metrics
Classes in org.axonframework.metrics with type parameters of type MessageMonitorModifier and TypeClassDescriptionclassPayloadTypeMessageMonitorWrapper<T extends MessageMonitor<Message<?>> & com.codahale.metrics.MetricSet>AMessageMonitorimplementation which creates a new MessageMonitor for everyMessagepayload type ingested by it.Classes in org.axonframework.metrics that implement MessageMonitorModifier and TypeClassDescriptionclassCalculates capacity by tracking, within the configured time window, the average message processing time and multiplying that by the amount of messages processed.classAMessageMonitorimplementation dedicated toEventMessages.classCounts the number of ingested, successful, failed and processed messagesclassAMessageMonitorwhich createsTimerinstances for the overall, success, failure and ignored time an ingestedMessagetakes.classPayloadTypeMessageMonitorWrapper<T extends MessageMonitor<Message<?>> & com.codahale.metrics.MetricSet>AMessageMonitorimplementation which creates a new MessageMonitor for everyMessagepayload type ingested by it.Methods in org.axonframework.metrics that return MessageMonitorModifier and TypeMethodDescriptionMessageMonitor<? super CommandMessage<?>> GlobalMetricRegistry.registerCommandBus(String commandBusName) Registers new metrics to the registry to monitor aCommandBus.MessageMonitor<? extends Message<?>> GlobalMetricRegistry.registerComponent(Class<?> componentType, String componentName) Registers new metrics to theMetricRegistryto monitor a component of givencomponentType.MessageMonitor<? super EventMessage<?>> GlobalMetricRegistry.registerEventBus(String eventBusName) Registers new metrics to the registry to monitor anEventBus.MessageMonitor<? super EventMessage<?>> GlobalMetricRegistry.registerEventProcessor(String eventProcessorName) Registers new metrics to the registry to monitor anEventProcessor.MessageMonitor<? super QueryMessage<?, ?>> GlobalMetricRegistry.registerQueryBus(String queryBusName) Registers new metrics to the registry to monitor aQueryBus. -
Uses of MessageMonitor in org.axonframework.micrometer
Classes in org.axonframework.micrometer with type parameters of type MessageMonitorModifier and TypeClassDescriptionclassPayloadTypeMessageMonitorWrapper<T extends MessageMonitor<Message<?>>>Deprecated.Classes in org.axonframework.micrometer that implement MessageMonitorModifier and TypeClassDescriptionclassCalculates capacity by tracking, within the configured time window, the average message processing time and multiplying that by the amount of messages processed.classAMessageMonitorimplementation dedicated toEventMessages.classCounts the number of ingested, successful, failed and processed messagesclassAMessageMonitorwhich introduces aTimerfor the overall timer of allMessages being ingested, as well as a success, failure and ignoredTimer.classPayloadTypeMessageMonitorWrapper<T extends MessageMonitor<Message<?>>>Deprecated.As of release 4.4, replaced by usings on the monitor implementations.invalid reference
TagMethods in org.axonframework.micrometer that return MessageMonitorModifier and TypeMethodDescriptionMessageMonitor<? super CommandMessage<?>> GlobalMetricRegistry.registerCommandBus(String commandBusName) Registers new metrics to the registry to monitor aCommandBus.MessageMonitor<? super CommandMessage<?>> GlobalMetricRegistry.registerCommandBus(String commandBusName, Function<Message<?>, Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Registers new metrics to the registry to monitor aCommandBususingTags through the giventagsBuilder.MessageMonitor<? extends Message<?>> GlobalMetricRegistry.registerComponent(Class<?> componentType, String componentName) Registers new metrics to the registry to monitor a component of the givencomponentType.MessageMonitor<? extends Message<?>> GlobalMetricRegistry.registerComponentWithDefaultTags(Class<?> componentType, String componentName) Registers new metrics to the registry to monitor a component of the givencomponentType.MessageMonitor<? super EventMessage<?>> GlobalMetricRegistry.registerEventBus(String eventBusName) Registers new metrics to the registry to monitor anEventBus.MessageMonitor<? super EventMessage<?>> GlobalMetricRegistry.registerEventBus(String eventBusName, Function<Message<?>, Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Registers new metrics to the registry to monitor anEventBususingTags through the giventagsBuilder.MessageMonitor<? super EventMessage<?>> GlobalMetricRegistry.registerEventProcessor(String eventProcessorName) Registers new metrics to the registry to monitor anEventProcessor.MessageMonitor<? super EventMessage<?>> GlobalMetricRegistry.registerEventProcessor(String eventProcessorName, Function<Message<?>, Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Deprecated.Please use theGlobalMetricRegistry.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 anEventProcessorusingTags through the giventagsBuilder.MessageMonitor<? super QueryMessage<?, ?>> GlobalMetricRegistry.registerQueryBus(String queryBusName) Registers new metrics to the registry to monitor aQueryBus.MessageMonitor<? super QueryMessage<?, ?>> GlobalMetricRegistry.registerQueryBus(String queryBusName, Function<Message<?>, Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Registers new metrics to the registry to monitor aQueryBususingTags through the giventagsBuilder. -
Uses of MessageMonitor in org.axonframework.monitoring
Classes in org.axonframework.monitoring that implement MessageMonitorModifier and TypeClassDescriptionclassMultiMessageMonitor<T extends Message<?>>Delegates messages and callbacks to the given list of message monitorsenumA message monitor that returns a NoOp message callbackConstructors in org.axonframework.monitoring with parameters of type MessageMonitorModifierConstructorDescriptionMultiMessageMonitor(MessageMonitor<? super T>... messageMonitors) Initialize a message monitor with the givenmessageMonitors Constructor parameters in org.axonframework.monitoring with type arguments of type MessageMonitorModifierConstructorDescriptionMultiMessageMonitor(List<MessageMonitor<? super T>> messageMonitors) Initialize a message monitor with the given list ofmessageMonitors -
Uses of MessageMonitor in org.axonframework.queryhandling
Methods in org.axonframework.queryhandling with parameters of type MessageMonitorModifier and TypeMethodDescriptionSimpleQueryBus.Builder.messageMonitor(MessageMonitor<? super QueryMessage<?, ?>> messageMonitor) Sets theMessageMonitorused to monitor query messages.SimpleQueryUpdateEmitter.Builder.updateMessageMonitor(MessageMonitor<? super SubscriptionQueryUpdateMessage<?>> updateMessageMonitor) Sets theMessageMonitorused to monitorSubscriptionQueryUpdateMessages being processed. -
Uses of MessageMonitor in org.axonframework.spring.config
Methods in org.axonframework.spring.config that return MessageMonitorModifier and TypeMethodDescription<M extends Message<?>>
MessageMonitor<? super M> AxonConfiguration.messageMonitor(Class<?> componentType, String componentName) Deprecated.
invalid reference