Uses of Interface
org.axonframework.eventhandling.Cluster

Packages that use Cluster

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

Uses of Cluster in org.axonframework.eventhandling

Classes in org.axonframework.eventhandling that implement Cluster

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.

Methods in org.axonframework.eventhandling that return Cluster

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)

Methods in org.axonframework.eventhandling with parameters of type Cluster

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.

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

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 parameters in org.axonframework.eventhandling with type arguments of type Cluster

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.

Uses of Cluster in org.axonframework.eventhandling.amqp.spring

Methods in org.axonframework.eventhandling.amqp.spring with parameters of type Cluster

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.

Constructors in org.axonframework.eventhandling.amqp.spring with parameters of type Cluster

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.

Uses of Cluster in org.axonframework.eventhandling.async

Classes in org.axonframework.eventhandling.async that implement Cluster

Modifier and Type	Class and Description
class	AsynchronousCluster Cluster implementation that publishes events to the subscribed Event Listeners asynchronously from the publishing thread.

Uses of Cluster in org.axonframework.eventhandling.replay

Classes in org.axonframework.eventhandling.replay that implement Cluster

Modifier and Type	Class and Description
class	ReplayingCluster Cluster implementation that wraps another Cluster, adding the capability to replay events from an Event Store.

Methods in org.axonframework.eventhandling.replay with parameters of type Cluster

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)

Constructors in org.axonframework.eventhandling.replay with parameters of type Cluster

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.