Package | Description |
---|---|
org.axonframework.commandhandling.distributed | |
org.axonframework.jgroups.commandhandling | |
org.axonframework.springcloud.commandhandling |
Modifier and Type | Class and Description |
---|---|
static class |
ConsistentHash.ConsistentHashMember
Member implementation used by a
ConsistentHash registry. |
class |
SimpleMember<E>
An endpoint in the network for a command handling service.
|
Modifier and Type | Method and Description |
---|---|
Optional<Member> |
CommandRouter.findDestination(CommandMessage<?> message)
Returns the member instance to which the given
message should be routed. |
Optional<Member> |
ConsistentHash.getMember(String routingKey,
CommandMessage<?> commandMessage)
Returns the member instance to which the given
message should be routed. |
Set<Member> |
ConsistentHash.getMembers()
Returns the set of members registered with this consistent hash instance.
|
Modifier and Type | Method and Description |
---|---|
<C> void |
CommandBusConnector.send(Member destination,
CommandMessage<? extends C> command)
Sends the given
command to the node assigned to handle messages with the given
routingKey . |
<C,R> void |
CommandBusConnector.send(Member destination,
CommandMessage<C> command,
CommandCallback<? super C,R> callback)
Sends the given
command to the node assigned to handle messages with the given
routingKey . |
ConsistentHash |
ConsistentHash.with(Member member,
int loadFactor,
Predicate<? super CommandMessage<?>> commandFilter)
Registers the given
member with given loadFactor and commandFilter if it is not
already contained in the ConsistentHash . |
ConsistentHash |
ConsistentHash.without(Member member)
Deregisters the given
member and returns a new ConsistentHash with updated memberships. |
Modifier and Type | Method and Description |
---|---|
Optional<Member> |
JGroupsConnector.findDestination(CommandMessage<?> message) |
Modifier and Type | Method and Description |
---|---|
protected org.jgroups.Address |
JGroupsConnector.resolveAddress(Member destination)
Resolve the JGroups Address of the given
Member . |
<C> void |
JGroupsConnector.send(Member destination,
CommandMessage<? extends C> command) |
<C,R> void |
JGroupsConnector.send(Member destination,
CommandMessage<C> command,
CommandCallback<? super C,R> callback) |
Modifier and Type | Method and Description |
---|---|
Optional<Member> |
SpringCloudCommandRouter.findDestination(CommandMessage<?> commandMessage) |
Modifier and Type | Method and Description |
---|---|
<C> void |
SpringHttpCommandBusConnector.send(Member destination,
CommandMessage<? extends C> commandMessage) |
<C,R> void |
SpringHttpCommandBusConnector.send(Member destination,
CommandMessage<C> commandMessage,
CommandCallback<? super C,R> callback) |
Copyright © 2010–2017. All rights reserved.