Uses of Interface
org.axonframework.messaging.monitoring.MessageMonitor
Packages that use MessageMonitor
Package
Description
A collection of classes which may prove useful when testing Axon-based classes.
-
Uses of MessageMonitor in org.axonframework.extension.metrics.dropwizard
Classes in org.axonframework.extension.metrics.dropwizard 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.extension.metrics.dropwizard 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.extension.metrics.dropwizard 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.extension.metrics.micrometer
Classes in org.axonframework.extension.metrics.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.Methods in org.axonframework.extension.metrics.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, 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.messaging.core.configuration
Method parameters in org.axonframework.messaging.core.configuration with type arguments of type MessageMonitorModifier and TypeMethodDescriptionMessagingConfigurer.registerCommandMonitor(ComponentBuilder<MessageMonitor<? super CommandMessage>> messageMonitorBuilder) Registers a command monitor using the given message monitor builder.MessagingConfigurer.registerEventMonitor(ComponentBuilder<MessageMonitor<? super EventMessage>> messageMonitorBuilder) Registers a component builder to configure theMessageMonitorused for monitoringEventMessage.MessagingConfigurer.registerMessageMonitor(ComponentBuilder<MessageMonitor<Message>> messageMonitorBuilder) Registers a message monitor for the messaging components in the configuration.MessagingConfigurer.registerQueryMonitor(ComponentBuilder<MessageMonitor<? super QueryMessage>> messageMonitorBuilder) Registers a query monitor using the specifiedmessageMonitorBuilder.MessagingConfigurer.registerSubscriptionQueryUpdateMonitor(ComponentBuilder<MessageMonitor<? super SubscriptionQueryUpdateMessage>> messageMonitorBuilder) Registers a subscription query update monitor using the specifiedmessageMonitorBuilder. -
Uses of MessageMonitor in org.axonframework.messaging.eventhandling.configuration
Fields in org.axonframework.messaging.eventhandling.configuration declared as MessageMonitorModifier and TypeFieldDescriptionprotected MessageMonitor<? super EventMessage> EventProcessorConfiguration.messageMonitor -
Uses of MessageMonitor in org.axonframework.messaging.monitoring
Classes in org.axonframework.messaging.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 callbackMethods in org.axonframework.messaging.monitoring that return types with arguments of type MessageMonitorModifier and TypeMethodDescriptionList<MessageMonitor<? super T>> MultiMessageMonitor.messageMonitors()Inspect the contained message monitors.Constructors in org.axonframework.messaging.monitoring with parameters of type MessageMonitorModifierConstructorDescriptionMultiMessageMonitor(MessageMonitor<? super T>... messageMonitors) Initialize a message monitor with the givenmessageMonitors Constructor parameters in org.axonframework.messaging.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.messaging.monitoring.configuration
Methods in org.axonframework.messaging.monitoring.configuration that return MessageMonitorModifier and TypeMethodDescriptionMessageMonitor<? super CommandMessage> DefaultMessageMonitorRegistry.commandMonitor(Configuration config) MessageMonitor<? super CommandMessage> MessageMonitorRegistry.commandMonitor(Configuration config) Retrieves aMessageMonitordedicated for monitoringCommandMessageprocessing.MessageMonitor<? super EventMessage> DefaultMessageMonitorRegistry.eventMonitor(Configuration config) MessageMonitor<? super EventMessage> MessageMonitorRegistry.eventMonitor(Configuration config) Retrieves aMessageMonitorspecifically designed to monitor the processing ofEventMessageinstances.MessageMonitor<? super QueryMessage> DefaultMessageMonitorRegistry.queryMonitor(Configuration config) MessageMonitor<? super QueryMessage> MessageMonitorRegistry.queryMonitor(Configuration config) Retrieves aMessageMonitorfor monitoring the processing ofQueryMessageinstances.DefaultMessageMonitorRegistry.subscriptionQueryUpdateMonitor(Configuration config) MessageMonitorRegistry.subscriptionQueryUpdateMonitor(Configuration config) Retrieves aMessageMonitorfor monitoring the processing ofSubscriptionQueryUpdateMessageinstances.Method parameters in org.axonframework.messaging.monitoring.configuration with type arguments of type MessageMonitorModifier and TypeMethodDescriptionDefaultMessageMonitorRegistry.registerCommandMonitor(ComponentBuilder<MessageMonitor<? super CommandMessage>> monitorBuilder) MessageMonitorRegistry.registerCommandMonitor(ComponentBuilder<MessageMonitor<? super CommandMessage>> monitorBuilder) Registers aMessageMonitorspecifically for monitoring the processing ofCommandMessageinstances.DefaultMessageMonitorRegistry.registerEventMonitor(ComponentBuilder<MessageMonitor<? super EventMessage>> monitorBuilder) MessageMonitorRegistry.registerEventMonitor(ComponentBuilder<MessageMonitor<? super EventMessage>> monitorBuilder) Registers aMessageMonitorspecific forEventMessagetypes using the supplied monitor builder.DefaultMessageMonitorRegistry.registerMonitor(ComponentBuilder<MessageMonitor<Message>> monitorBuilder) MessageMonitorRegistry.registerMonitor(ComponentBuilder<MessageMonitor<Message>> monitorBuilder) Registers aMessageMonitorfor genericMessagetypes using the supplied monitor builder.DefaultMessageMonitorRegistry.registerQueryMonitor(ComponentBuilder<MessageMonitor<? super QueryMessage>> monitorBuilder) MessageMonitorRegistry.registerQueryMonitor(ComponentBuilder<MessageMonitor<? super QueryMessage>> monitorBuilder) DefaultMessageMonitorRegistry.registerSubscriptionQueryUpdateMonitor(ComponentBuilder<MessageMonitor<? super SubscriptionQueryUpdateMessage>> monitorBuilder) MessageMonitorRegistry.registerSubscriptionQueryUpdateMonitor(ComponentBuilder<MessageMonitor<? super SubscriptionQueryUpdateMessage>> monitorBuilder) Registers aMessageMonitorspecifically forSubscriptionQueryUpdateMessagetypes using the providedComponentBuilder. -
Uses of MessageMonitor in org.axonframework.messaging.monitoring.interception
Constructors in org.axonframework.messaging.monitoring.interception with parameters of type MessageMonitorModifierConstructorDescriptionMonitoringCommandHandlerInterceptor(MessageMonitor<? super CommandMessage> messageMonitor) Constructs a MonitoringCommandHandlerInterceptor using the givenMessageMonitor.MonitoringEventDispatchInterceptor(MessageMonitor<? super EventMessage> messageMonitor) Constructs a new MonitoringEventDispatchInterceptor using the givenMessageMonitor.MonitoringEventHandlerInterceptor(MessageMonitor<? super EventMessage> messageMonitor) Constructs a new MonitoringEventHandlerInterceptor using the givenMessageMonitor.MonitoringQueryHandlerInterceptor(MessageMonitor<? super QueryMessage> messageMonitor) Constructs a MonitoringQueryHandlerInterceptor using the givenMessageMonitor.MonitoringSubscriptionQueryUpdateDispatchInterceptor(MessageMonitor<? super SubscriptionQueryUpdateMessage> messageMonitor) Constructs a new MonitoringSubscriptionQueryUpdateDispatchInterceptor using the givenMessageMonitor. -
Uses of MessageMonitor in org.axonframework.test.util
Classes in org.axonframework.test.util that implement MessageMonitorModifier and TypeClassDescriptionclassA message monitor implementation that records the processing results of messages in the providedMessageMonitorReportinstances.