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.metrics | |
org.axonframework.monitoring | |
org.axonframework.queryhandling | |
org.axonframework.spring.config |
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 |
Modifier and Type | Method and Description |
---|---|
MessageMonitor<? super CommandMessage<?>> |
DisruptorConfiguration.getMessageMonitor()
Returns the message monitor to use.
|
Modifier and Type | Method and Description |
---|---|
DisruptorConfiguration |
DisruptorConfiguration.setMessageMonitor(MessageMonitor<? super CommandMessage<?>> messageMonitor)
Sets the message monitor to use.
|
Constructor and Description |
---|
DistributedCommandBus(CommandRouter commandRouter,
CommandBusConnector connector,
MessageMonitor<? super CommandMessage<?>> messageMonitor)
Initializes the command bus with the given
commandRouter , connector and 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<?>> |
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.
|
SagaConfiguration<S> |
SagaConfiguration.configureMessageMonitor(Function<Configuration,MessageMonitor<? super EventMessage<?>>> messageMonitor)
Configures a MessageMonitor to be used to monitor Events processed on by the Saga being configured.
|
EventHandlingConfiguration |
EventHandlingConfiguration.configureMessageMonitor(String name,
Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)
Configures the builder function to create the Message Monitor for the
EventProcessor of the given name. |
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. |
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)
|
EmbeddedEventStore(EventStorageEngine storageEngine,
MessageMonitor<? super EventMessage<?>> monitor,
int cachedEvents,
long fetchDelay,
long cleanupDelay,
TimeUnit timeUnit)
|
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
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. |
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 . |
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
|
Constructor and Description |
---|
SimpleQueryBus(MessageMonitor<? super QueryMessage<?,?>> messageMonitor,
TransactionManager transactionManager,
QueryInvocationErrorHandler errorHandler)
Initialize the query bus with the given
messageMonitor and given errorHandler . |
Modifier and Type | Method and Description |
---|---|
<M extends Message<?>> |
AxonConfiguration.messageMonitor(Class<?> componentType,
String componentName) |
Copyright © 2010–2017. All rights reserved.