Package | Description |
---|---|
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.eventhandling.amqp.spring | |
org.axonframework.eventhandling.async | |
org.axonframework.eventhandling.replay |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCluster
Abstract
Cluster implementation that keeps track of Cluster members (EventListeners ). |
class |
SimpleCluster
A simple Cluster implementation that invokes each of the members of a cluster when an Event is published.
|
Modifier and Type | Method and Description |
---|---|
Cluster |
ClassNamePatternClusterSelector.doSelectCluster(EventListener eventListener,
Class listenerType) |
Cluster |
ClassNamePrefixClusterSelector.doSelectCluster(EventListener eventListener,
Class<?> listenerType) |
protected Cluster |
AnnotationClusterSelector.doSelectCluster(EventListener eventListener,
Class<?> listenerType) |
protected abstract Cluster |
AbstractClusterSelector.doSelectCluster(EventListener eventListener,
Class<?> listenerType)
Select a cluster for the given
eventListener , which has the actual class listenerType . |
Cluster |
SimpleClusterFactoryBean.getObject() |
Cluster |
DefaultClusterSelector.selectCluster(EventListener eventListener)
Selects the cluster instance that the given
eventListener should be member of. |
Cluster |
CompositeClusterSelector.selectCluster(EventListener eventListener) |
Cluster |
ClusterSelector.selectCluster(EventListener eventListener)
Selects the cluster instance that the given
eventListener should be member of. |
Cluster |
AutowiringClusterSelector.selectCluster(EventListener eventListener) |
Cluster |
AbstractClusterSelector.selectCluster(EventListener eventListener) |
Modifier and Type | Method and Description |
---|---|
void |
EventBusTerminal.onClusterCreated(Cluster cluster)
Invoked when an Event Listener has been assigned to a cluster that was not yet known to the Event Bus.
|
Constructor and Description |
---|
AnnotationClusterSelector(Class<? extends Annotation> annotationType,
Cluster cluster)
Initializes a ClusterSelector instance that selects the given
cluster for Event Listeners that are
annotated with the given annotationType . |
AnnotationClusterSelector(Class<? extends Annotation> annotationType,
Cluster cluster,
boolean inspectSuperClasses)
Initializes a ClusterSelector instance that selects the given
cluster for Event Listeners that are
annotated with the given annotationType . |
ClassNamePatternClusterSelector(Pattern pattern,
Cluster cluster)
Initializes the ClassNamePrefixClusterSelector using the given
mappings . |
ClassNamePrefixClusterSelector(Map<String,Cluster> mappings,
Cluster defaultCluster)
Initializes the ClassNamePrefixClusterSelector using the given
mappings . |
ClassNamePrefixClusterSelector(String prefix,
Cluster cluster)
Initializes the ClassNamePrefixClusterSelector where classes starting with the given
prefix will be
mapped to the given cluster . |
DefaultClusterSelector(Cluster defaultCluster)
Initializes the DefaultClusterSelector to assign the given
defaultCluster to each listener. |
Constructor and Description |
---|
ClassNamePrefixClusterSelector(Map<String,Cluster> mappings)
Initializes the ClassNamePrefixClusterSelector using the given
mappings . |
ClassNamePrefixClusterSelector(Map<String,Cluster> mappings,
Cluster defaultCluster)
Initializes the ClassNamePrefixClusterSelector using the given
mappings . |
Modifier and Type | Method and Description |
---|---|
void |
ClusterMessageListener.addCluster(Cluster cluster)
Registers an additional cluster.
|
void |
SpringAMQPTerminal.onClusterCreated(Cluster cluster) |
void |
ListenerContainerLifecycleManager.registerCluster(Cluster cluster,
AMQPConsumerConfiguration config,
AMQPMessageConverter messageConverter)
Registers the given
cluster , assigning it to a listener that listens to the given
queueName . |
Constructor and Description |
---|
ClusterMessageListener(Cluster initialCluster,
AMQPMessageConverter messageConverter)
Initializes a ClusterMessageListener with given
initialCluster that uses given
serializer to deserialize the message's contents into an EventMessage. |
Modifier and Type | Class and Description |
---|---|
class |
AsynchronousCluster
Cluster implementation that publishes events to the subscribed Event Listeners asynchronously from the publishing
thread.
|
Modifier and Type | Class and Description |
---|---|
class |
ReplayingCluster
Cluster implementation that wraps another Cluster, adding the capability to replay events from an Event Store.
|
Modifier and Type | Method and Description |
---|---|
List<EventMessage> |
IncomingMessageHandler.onIncomingMessages(Cluster destination,
EventMessage... messages)
Invoked while the ReplayingCluster is in replay mode and an Event is being dispatched to the Cluster.
|
List<EventMessage> |
DiscardingIncomingMessageHandler.onIncomingMessages(Cluster destination,
EventMessage... messages) |
List<EventMessage> |
BackloggingIncomingMessageHandler.onIncomingMessages(Cluster destination,
EventMessage... messages) |
void |
IncomingMessageHandler.onReplayFailed(Cluster destination,
Throwable cause)
Invoked when a replay has failed.
|
void |
DiscardingIncomingMessageHandler.onReplayFailed(Cluster destination,
Throwable cause) |
void |
BackloggingIncomingMessageHandler.onReplayFailed(Cluster destination,
Throwable cause) |
void |
IncomingMessageHandler.prepareForReplay(Cluster destination)
Invoked just before replay mode is activated.
|
void |
DiscardingIncomingMessageHandler.prepareForReplay(Cluster destination) |
void |
BackloggingIncomingMessageHandler.prepareForReplay(Cluster destination) |
void |
IncomingMessageHandler.processBacklog(Cluster destination)
Invoked when all events from the Event Store have been processed.
|
void |
DiscardingIncomingMessageHandler.processBacklog(Cluster destination) |
void |
BackloggingIncomingMessageHandler.processBacklog(Cluster destination) |
List<EventMessage> |
IncomingMessageHandler.releaseMessage(Cluster destination,
DomainEventMessage message)
Invoked when a message has been replayed from the event store.
|
List<EventMessage> |
DiscardingIncomingMessageHandler.releaseMessage(Cluster destination,
DomainEventMessage message) |
List<EventMessage> |
BackloggingIncomingMessageHandler.releaseMessage(Cluster destination,
DomainEventMessage message) |
Constructor and Description |
---|
ReplayingCluster(Cluster delegate,
EventStoreManagement eventStore,
TransactionManager transactionManager,
int commitThreshold,
IncomingMessageHandler incomingMessageHandler)
Initializes a ReplayingCluster that wraps the given
delegate , to allow it to replay event from the
given eventStore . |
Copyright © 2010-2014. All Rights Reserved.