org.axonframework.springcloud.commandhandling

Class SpringCloudCommandRouter

java.lang.Object

org.axonframework.springcloud.commandhandling.SpringCloudCommandRouter

All Implemented Interfaces:

CommandRouter

public class SpringCloudCommandRouter
extends Object
implements CommandRouter

A CommandRouter implementation which uses Spring Clouds DiscoveryClients to discover and notify other nodes for routing Commands.

Constructor Summary

Constructors

Constructor and Description
SpringCloudCommandRouter(org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient, RoutingStrategy routingStrategy) Initialize a CommandRouter with the given DiscoveryClient to update it's own membership as a CommandRouter and to create it's own awareness of available nodes to send commands to in a ConsistentHash.
SpringCloudCommandRouter(org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient, RoutingStrategy routingStrategy, Serializer serializer) Deprecated. serializer is no longer customizable

Method Summary

Modifier and Type	Method and Description
Optional<Member>	findDestination(CommandMessage<?> commandMessage) Returns the member instance to which the given message should be routed.
void	updateMembership(int loadFactor, Predicate<? super CommandMessage<?>> commandFilter) Updates the load factor and capabilities of this member representing the current endpoint if the implementation allows memberships to be updated dynamically.
void	updateMemberships(org.springframework.cloud.client.discovery.event.HeartbeatEvent event)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SpringCloudCommandRouter

@Deprecated
public SpringCloudCommandRouter(org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient,
                                             RoutingStrategy routingStrategy,
                                             Serializer serializer)

Deprecated. serializer is no longer customizable

Initialize a CommandRouter with the given DiscoveryClient to update it's own membership as a CommandRouter and to create it's own awareness of available nodes to send commands to in a ConsistentHash. The routingStrategy is used to define the key based on which Command Messages are routed to their respective handler nodes. The serializer is used to serialize this node it's set of Commands it can handle to be added as meta data to this ServiceInstance

Parameters:

discoveryClient - The DiscoveryClient used to discovery and notify other nodes

routingStrategy - The strategy for routing Commands to a Node

serializer - The serializer used to serialize this node it's set of Commands it can handle

SpringCloudCommandRouter

public SpringCloudCommandRouter(org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient,
                                RoutingStrategy routingStrategy)

Initialize a CommandRouter with the given DiscoveryClient to update it's own membership as a CommandRouter and to create it's own awareness of available nodes to send commands to in a ConsistentHash. The routingStrategy is used to define the key based on which Command Messages are routed to their respective handler nodes.

Parameters:

discoveryClient - The DiscoveryClient used to discovery and notify other nodes

routingStrategy - The strategy for routing Commands to a Node

Method Detail

findDestination

public Optional<Member> findDestination(CommandMessage<?> commandMessage)

Description copied from interface: CommandRouter

Returns the member instance to which the given message should be routed. If no suitable member could be found an empty Optional is returned.

Specified by:

findDestination in interface CommandRouter

Parameters:

commandMessage - the command message to find a member for

Returns:

the member that should handle the message or an empty Optional if no suitable member was found

updateMembership

public void updateMembership(int loadFactor,
                             Predicate<? super CommandMessage<?>> commandFilter)

Description copied from interface: CommandRouter

Updates the load factor and capabilities of this member representing the current endpoint if the implementation allows memberships to be updated dynamically.

Specified by:

updateMembership in interface CommandRouter

Parameters:

loadFactor - the new load factor of the member for this endpoint

commandFilter - the new capabilities of the member for this endpoint

updateMemberships

@EventListener
public void updateMemberships(org.springframework.cloud.client.discovery.event.HeartbeatEvent event)