Package | Description |
---|---|
org.axonframework.commandhandling.distributed |
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,
CommandMessageFilter 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. |
Copyright © 2010–2020. All rights reserved.