A C D E G H I J M N O R S T U V W

A

AbstractRoutingStrategy - Class in org.axonframework.commandhandling.distributed

Abstract implementation of the RoutingStrategy interface that uses a policy to prescribe what happens when a routing cannot be resolved.

AbstractRoutingStrategy(UnresolvedRoutingKeyPolicy) - Constructor for class org.axonframework.commandhandling.distributed.AbstractRoutingStrategy

Initializes the strategy using given unresolvedRoutingKeyPolicy prescribing what happens when a routing key cannot be resolved.

afterPropertiesSet() - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

AnnotationRoutingStrategy - Class in org.axonframework.commandhandling.distributed

RoutingStrategy that expects an TargetAggregateIdentifier annotation on the command message's payload.

AnnotationRoutingStrategy() - Constructor for class org.axonframework.commandhandling.distributed.AnnotationRoutingStrategy

Initializes a Routing Strategy that fails when an incoming command does not define an AggregateIdentifier to base the routing key on.

AnnotationRoutingStrategy(Class<? extends Annotation>) - Constructor for class org.axonframework.commandhandling.distributed.AnnotationRoutingStrategy

Initializes a Routing Strategy that uses the given annotation to resolve the targeted identifier.

AnnotationRoutingStrategy(UnresolvedRoutingKeyPolicy) - Constructor for class org.axonframework.commandhandling.distributed.AnnotationRoutingStrategy

Initializes a Routing Strategy that uses the given unresolvedRoutingKeyPolicy when an incoming command does not define an AggregateIdentifier to base the routing key on.

AnnotationRoutingStrategy(Class<? extends Annotation>, UnresolvedRoutingKeyPolicy) - Constructor for class org.axonframework.commandhandling.distributed.AnnotationRoutingStrategy

Initializes a Routing Strategy that uses the given annotation to resolve the targeted identifier and the given unresolvedRoutingKeyPolicy when an incoming command does not define an AggregateIdentifier to base the routing key on.

awaitJoined() - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnector

this method blocks until this member has successfully joined the other members, until the thread is interrupted, or when joining has failed.

awaitJoined(long, TimeUnit) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnector

this method blocks until this member has successfully joined the other members, until the thread is interrupted, when the given number of milliseconds have passed, or when joining has failed.

C

CommandBusConnector - Interface in org.axonframework.commandhandling.distributed

Interface describing the component that remotely connects multiple CommandBus instances.

CommandDispatchException - Exception in org.axonframework.commandhandling.distributed

Exception indicating that an error has occurred while trying to dispatch a command to another (potentially remote) segment of the CommandBus.

CommandDispatchException(String) - Constructor for exception org.axonframework.commandhandling.distributed.CommandDispatchException

Initializes the exception using the given message.

CommandDispatchException(String, Throwable) - Constructor for exception org.axonframework.commandhandling.distributed.CommandDispatchException

Initializes the exception using the given message and cause.

CommandResponseProcessingFailedException - Exception in org.axonframework.commandhandling.distributed.jgroups

Exception indicating that a failure occurred during processing of a command response.

CommandResponseProcessingFailedException(String) - Constructor for exception org.axonframework.commandhandling.distributed.jgroups.CommandResponseProcessingFailedException

Initializes the exception using the given message.

CommandResponseProcessingFailedException(String, Throwable) - Constructor for exception org.axonframework.commandhandling.distributed.jgroups.CommandResponseProcessingFailedException

Initializes the exception using the given message and cause.

connect(int) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnector

Connects this member to the cluster using the given loadFactor.

ConnectionFailedException - Exception in org.axonframework.commandhandling.distributed.jgroups

Exception indicating that a CommandBusConnector failed to connect to other instances.

ConnectionFailedException(String) - Constructor for exception org.axonframework.commandhandling.distributed.jgroups.ConnectionFailedException

Initializes the exception using the given message.

ConnectionFailedException(String, Throwable) - Constructor for exception org.axonframework.commandhandling.distributed.jgroups.ConnectionFailedException

Initializes the exception using the given message and cause.

ConsistentHash - Class in org.axonframework.commandhandling.distributed

Basic implementation of a Consistent Hashing algorithm, using the MD5 algorithm to build the hash values for given keys and node names.

ConsistentHash() - Constructor for class org.axonframework.commandhandling.distributed.ConsistentHash

Initializes an empty hash.

ConsistentHash.Member - Class in org.axonframework.commandhandling.distributed

Represents a member in a consistently hashed cluster.

ConsistentHash.Member(String, int, Set<String>) - Constructor for class org.axonframework.commandhandling.distributed.ConsistentHash.Member

Constructs a new member with given nodeName, segmentCount supporting given supportedCommandTypes.

D

dispatch(CommandMessage<?>) - Method in class org.axonframework.commandhandling.distributed.DistributedCommandBus

dispatch(CommandMessage<?>, CommandCallback<R>) - Method in class org.axonframework.commandhandling.distributed.DistributedCommandBus

DispatchMessage - Class in org.axonframework.commandhandling.distributed.jgroups

JGroups message that contains a CommandMessage that needs to be dispatched on a remote command bus segment.

DispatchMessage() - Constructor for class org.axonframework.commandhandling.distributed.jgroups.DispatchMessage

Default constructor required by the Streamable and Externalizable interfaces.

DispatchMessage(CommandMessage<?>, Serializer, boolean) - Constructor for class org.axonframework.commandhandling.distributed.jgroups.DispatchMessage

Initialized a DispatchMessage for the given commandMessage, to be serialized using given serializer.

DistributedCommandBus - Class in org.axonframework.commandhandling.distributed

Implementation of a CommandBus that is aware of multiple instances of a CommandBus working together to spread load.

DistributedCommandBus(CommandBusConnector) - Constructor for class org.axonframework.commandhandling.distributed.DistributedCommandBus

Initializes the command bus with the given connector and an AnnotationRoutingStrategy.

DistributedCommandBus(CommandBusConnector, RoutingStrategy) - Constructor for class org.axonframework.commandhandling.distributed.DistributedCommandBus

Initializes the command bus with the given connector and routingStrategy.

doResolveRoutingKey(CommandMessage<?>) - Method in class org.axonframework.commandhandling.distributed.AbstractRoutingStrategy

Resolve the Routing Key for the given command.

doResolveRoutingKey(CommandMessage<?>) - Method in class org.axonframework.commandhandling.distributed.AnnotationRoutingStrategy

doResolveRoutingKey(CommandMessage<?>) - Method in class org.axonframework.commandhandling.distributed.MetaDataRoutingStrategy

E

emptyRing() - Static method in class org.axonframework.commandhandling.distributed.ConsistentHash

Returns an instance of an empty Ring, which can be used to add members.

equals(Object) - Method in class org.axonframework.commandhandling.distributed.ConsistentHash

equals(Object) - Method in class org.axonframework.commandhandling.distributed.ConsistentHash.Member

G

getCommandIdentifier() - Method in class org.axonframework.commandhandling.distributed.jgroups.DispatchMessage

Returns the identifier of the command carried by this instance.

getCommandIdentifier() - Method in class org.axonframework.commandhandling.distributed.jgroups.ReplyMessage

Returns the identifier of the command for which this message is a reply.

getCommandMessage(Serializer) - Method in class org.axonframework.commandhandling.distributed.jgroups.DispatchMessage

Returns the CommandMessage wrapped in this Message.

getCommandNames() - Method in class org.axonframework.commandhandling.distributed.jgroups.JoinMessage

Returns a read-only view on the Command Names supported by the joining member.

getConsistentHash() - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnector

Returns the consistent hash on which current assignment of commands to nodes is being executed.

getError(Serializer) - Method in class org.axonframework.commandhandling.distributed.jgroups.ReplyMessage

Returns the error of the command processing.

getLoadFactor() - Method in class org.axonframework.commandhandling.distributed.jgroups.JoinMessage

Returns the loadFactor the member wishes to join with.

getMember(String, String) - Method in class org.axonframework.commandhandling.distributed.ConsistentHash

Returns the member for the given item, that supports given commandType.

getMembers() - Method in class org.axonframework.commandhandling.distributed.ConsistentHash

Returns the set of members part of this hash ring.

getMembers() - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnector

Returns the set of members currently registered with the connector.

getNodeName() - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnector

Returns the name of this node in the cluster, or null if this member is not connected.

getObject() - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

getObjectType() - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

getPhase() - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

getReturnValue(Serializer) - Method in class org.axonframework.commandhandling.distributed.jgroups.ReplyMessage

Returns the returnValue of the command processing.

getRoutingKey(CommandMessage<?>) - Method in class org.axonframework.commandhandling.distributed.AbstractRoutingStrategy

getRoutingKey(CommandMessage<?>) - Method in interface org.axonframework.commandhandling.distributed.RoutingStrategy

Generates a routing key for the given command.

H

hashChanged(ConsistentHash) - Method in interface org.axonframework.commandhandling.distributed.jgroups.HashChangeListener

Invoked when the memberships of a consistent hash have changed.

HashChangeListener - Interface in org.axonframework.commandhandling.distributed.jgroups

Receive updates from the JGroupsConnector when the consistent hash changes.

hashCode() - Method in class org.axonframework.commandhandling.distributed.ConsistentHash

hashCode() - Method in class org.axonframework.commandhandling.distributed.ConsistentHash.Member

hashes() - Method in class org.axonframework.commandhandling.distributed.ConsistentHash.Member

Returns the hash values assigned to this member.

I

isAutoStartup() - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

isExpectReply() - Method in class org.axonframework.commandhandling.distributed.jgroups.DispatchMessage

Indicates whether the sender of this message requests a reply.

isMemberLive(View) - Method in class org.axonframework.commandhandling.distributed.jgroups.support.callbacks.MemberAwareCommandCallback

Indicates whether the node responsible for providing the value to invoke the callback with is still alive in the given currentView.

isRunning() - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

isSingleton() - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

isSuccess() - Method in class org.axonframework.commandhandling.distributed.jgroups.ReplyMessage

Whether the reply message represents a successfully executed command.

J

JGroupsConnector - Class in org.axonframework.commandhandling.distributed.jgroups

A CommandBusConnector that uses JGroups to discover and connect to other JGroupsConnectors in the network.

JGroupsConnector(JChannel, String, CommandBus, Serializer) - Constructor for class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnector

Initializes the Connector using given resources.

JGroupsConnector(JChannel, String, CommandBus, Serializer, HashChangeListener) - Constructor for class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnector

Initializes the Connector using given resources.

JGroupsConnectorFactoryBean - Class in org.axonframework.commandhandling.distributed.jgroups

Spring Factory bean that creates a JGroupsConnector and starts it when the application context is started.

JGroupsConnectorFactoryBean() - Constructor for class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

JoinMessage - Class in org.axonframework.commandhandling.distributed.jgroups

This message represents a notification of a Member joining the DistributedCommandBus with a given loadFactor.

JoinMessage() - Constructor for class org.axonframework.commandhandling.distributed.jgroups.JoinMessage

Default constructor required by the Streamable and Externalizable interfaces.

JoinMessage(int, Set<String>) - Constructor for class org.axonframework.commandhandling.distributed.jgroups.JoinMessage

Initializes a JoinMessage with the given loadFactor.

M

MemberAwareCommandCallback<R> - Class in org.axonframework.commandhandling.distributed.jgroups.support.callbacks

Callback implementation which wraps another callback, and is aware of the JGroups node responsible for providing the value to invoke the wrapped callback with.

MemberAwareCommandCallback(Address, CommandCallback<R>) - Constructor for class org.axonframework.commandhandling.distributed.jgroups.support.callbacks.MemberAwareCommandCallback

Initialize the callback, where the given dest is responsible for providing the value to invoke the given callback with.

MembershipUpdateFailedException - Exception in org.axonframework.commandhandling.distributed.jgroups

Exception indicating that a node has failed to update its membership details with the other nodes.

MembershipUpdateFailedException(String) - Constructor for exception org.axonframework.commandhandling.distributed.jgroups.MembershipUpdateFailedException

Initializes the exception using the given message.

MembershipUpdateFailedException(String, Throwable) - Constructor for exception org.axonframework.commandhandling.distributed.jgroups.MembershipUpdateFailedException

Initializes the exception using the given message and cause.

MetaDataRoutingStrategy - Class in org.axonframework.commandhandling.distributed

RoutingStrategy implementation that uses the value in the MetaData of a CommandMessage assigned to a given key.

MetaDataRoutingStrategy(String) - Constructor for class org.axonframework.commandhandling.distributed.MetaDataRoutingStrategy

Initializes the MetaDataRoutingStrategy where the given metaDataKey is used to get the Meta Data value.

MetaDataRoutingStrategy(String, UnresolvedRoutingKeyPolicy) - Constructor for class org.axonframework.commandhandling.distributed.MetaDataRoutingStrategy

Initializes the MetaDataRoutingStrategy where the given metaDataKey is used to get the Meta Data value.

N

name() - Method in class org.axonframework.commandhandling.distributed.ConsistentHash.Member

Returns the name of this member.

O

onFailure(Throwable) - Method in class org.axonframework.commandhandling.distributed.jgroups.support.callbacks.MemberAwareCommandCallback

onFailure(Throwable) - Method in class org.axonframework.commandhandling.distributed.jgroups.support.callbacks.ReplyingCallback

onSuccess(R) - Method in class org.axonframework.commandhandling.distributed.jgroups.support.callbacks.MemberAwareCommandCallback

onSuccess(Object) - Method in class org.axonframework.commandhandling.distributed.jgroups.support.callbacks.ReplyingCallback

org.axonframework.commandhandling.distributed - package org.axonframework.commandhandling.distributed

org.axonframework.commandhandling.distributed.jgroups - package org.axonframework.commandhandling.distributed.jgroups

org.axonframework.commandhandling.distributed.jgroups.support.callbacks - package org.axonframework.commandhandling.distributed.jgroups.support.callbacks

R

readExternal(ObjectInput) - Method in class org.axonframework.commandhandling.distributed.ConsistentHash

readExternal(ObjectInput) - Method in class org.axonframework.commandhandling.distributed.jgroups.DispatchMessage

readExternal(ObjectInput) - Method in class org.axonframework.commandhandling.distributed.jgroups.JoinMessage

readExternal(ObjectInput) - Method in class org.axonframework.commandhandling.distributed.jgroups.ReplyMessage

readFrom(DataInput) - Method in class org.axonframework.commandhandling.distributed.jgroups.DispatchMessage

readFrom(DataInput) - Method in class org.axonframework.commandhandling.distributed.jgroups.JoinMessage

readFrom(DataInput) - Method in class org.axonframework.commandhandling.distributed.jgroups.ReplyMessage

RemoteCommandHandlingException - Exception in org.axonframework.commandhandling.distributed

Exception indicating that an error has occurred while remotely handling a command.

RemoteCommandHandlingException(String) - Constructor for exception org.axonframework.commandhandling.distributed.RemoteCommandHandlingException

Initializes the exception using the given message.

RemoteCommandHandlingException(String, Throwable) - Constructor for exception org.axonframework.commandhandling.distributed.RemoteCommandHandlingException

Initializes the exception using the given message and cause.

ReplyingCallback - Class in org.axonframework.commandhandling.distributed.jgroups.support.callbacks

Callback implementation that forwards the callback invocation as a reply to an incoming message.

ReplyingCallback(JChannel, Address, CommandMessage, Serializer) - Constructor for class org.axonframework.commandhandling.distributed.jgroups.support.callbacks.ReplyingCallback

Initialize the callback to send a reply for an incoming commandMessage to given address using the given channel.

ReplyMessage - Class in org.axonframework.commandhandling.distributed.jgroups

JGroups Message representing a reply to a dispatched command.

ReplyMessage() - Constructor for class org.axonframework.commandhandling.distributed.jgroups.ReplyMessage

Default constructor required by the Streamable and Externalizable interfaces.

ReplyMessage(String, Object, Throwable, Serializer) - Constructor for class org.axonframework.commandhandling.distributed.jgroups.ReplyMessage

Constructs a message containing a reply to the command with given commandIdentifier, containing either given returnValue or error, which uses the given serializer to deserialize its contents.

RoutingStrategy - Interface in org.axonframework.commandhandling.distributed

Interface describing a mechanism that generates a routing key for a given command.

S

segmentCount() - Method in class org.axonframework.commandhandling.distributed.ConsistentHash.Member

Returns the number of segments this member has on the consistent hash ring.

send(String, CommandMessage<?>) - Method in interface org.axonframework.commandhandling.distributed.CommandBusConnector

Sends the given command to the node assigned to handle messages with the given routingKey.

send(String, CommandMessage<?>, CommandCallback<R>) - Method in interface org.axonframework.commandhandling.distributed.CommandBusConnector

Sends the given command to the node assigned to handle messages with the given routingKey.

send(String, CommandMessage<?>, CommandCallback<R>) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnector

send(String, CommandMessage<?>) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnector

setApplicationContext(ApplicationContext) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

setBeanName(String) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

setChannelName(String) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

Optionally sets the logical channel name of the channel.

setClusterName(String) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

Sets the name of the cluster to subscribe to.

setCommandDispatchInterceptors(Collection<CommandDispatchInterceptor>) - Method in class org.axonframework.commandhandling.distributed.DistributedCommandBus

Sets the interceptors that intercept commands just prior to dispatching them.

setConfiguration(String) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

Sets the JGroups configuration file to load.

setHashChangeListener(HashChangeListener) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

Register a HashChangeListener with the JGroupsConnector.

setInterceptors(List<CommandHandlerInterceptor>) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

Sets the interceptor to use in the default local segment (a SimpleCommandBus).

setJoinTimeout(long) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

Sets the number of milliseconds to wait for this member to join the group.

setLoadFactor(int) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

Sets the load factor for this instance of the Distributed Command Bus.

setLocalSegment(CommandBus) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

Sets the CommandBus instance on which local commands must be dispatched.

setPhase(int) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

Sets the phase in which this bean must be started.

setSerializer(Serializer) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

Sets the serializer used to serialize events before they are dispatched to the destination.

start() - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

stop() - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

stop(Runnable) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

subscribe(String, CommandHandler<? super C>) - Method in interface org.axonframework.commandhandling.distributed.CommandBusConnector

Subscribe the given handler to commands of type commandType to the local segment of the command bus.

subscribe(String, CommandHandler<? super C>) - Method in class org.axonframework.commandhandling.distributed.DistributedCommandBus

In the DistributedCommandBus, the handler is subscribed to the local segment only.

subscribe(String, CommandHandler<? super C>) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnector

supportedCommands() - Method in class org.axonframework.commandhandling.distributed.ConsistentHash.Member

Returns the set of commands supported by this member.

T

toString() - Method in class org.axonframework.commandhandling.distributed.ConsistentHash

U

UnresolvedRoutingKeyPolicy - Enum in org.axonframework.commandhandling.distributed

unsubscribe(String, CommandHandler<? super C>) - Method in interface org.axonframework.commandhandling.distributed.CommandBusConnector

Unsubscribe the given handler to commands of type commandType.

unsubscribe(String, CommandHandler<? super C>) - Method in class org.axonframework.commandhandling.distributed.DistributedCommandBus

In the DistributedCommandBus, the handler is unsubscribed from the local segment only.

unsubscribe(String, CommandHandler<? super C>) - Method in class org.axonframework.commandhandling.distributed.jgroups.JGroupsConnector

V

valueOf(String) - Static method in enum org.axonframework.commandhandling.distributed.UnresolvedRoutingKeyPolicy

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.axonframework.commandhandling.distributed.UnresolvedRoutingKeyPolicy

Returns an array containing the constants of this enum type, in the order they are declared.

W

withAdditionalNode(String, int, Set<String>) - Method in class org.axonframework.commandhandling.distributed.ConsistentHash

Returns a ConsistentHash with the given additional nodeName, which is given segmentCount segments on the ring.

withExclusively(Collection<String>) - Method in class org.axonframework.commandhandling.distributed.ConsistentHash

Returns a ConsistentHash instance where only segments leading to the given nodes are available.

writeExternal(ObjectOutput) - Method in class org.axonframework.commandhandling.distributed.ConsistentHash

writeExternal(ObjectOutput) - Method in class org.axonframework.commandhandling.distributed.jgroups.DispatchMessage

writeExternal(ObjectOutput) - Method in class org.axonframework.commandhandling.distributed.jgroups.JoinMessage

writeExternal(ObjectOutput) - Method in class org.axonframework.commandhandling.distributed.jgroups.ReplyMessage

writeTo(DataOutput) - Method in class org.axonframework.commandhandling.distributed.jgroups.DispatchMessage

writeTo(DataOutput) - Method in class org.axonframework.commandhandling.distributed.jgroups.JoinMessage

writeTo(DataOutput) - Method in class org.axonframework.commandhandling.distributed.jgroups.ReplyMessage

A C D E G H I J M N O R S T U V W