|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 . |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |