Uses of Interface
org.axonframework.eventhandling.Cluster

Packages that use Cluster
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
 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
 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
 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
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
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
 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
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
 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
 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
 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
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-2016. All Rights Reserved.