org.axonframework.springcloud.commandhandling

Class SpringCloudCommandRouter

java.lang.Object

org.axonframework.springcloud.commandhandling.SpringCloudCommandRouter

All Implemented Interfaces:

CommandRouter

Direct Known Subclasses:

SpringCloudHttpBackupCommandRouter

public class SpringCloudCommandRouter
extends Object
implements CommandRouter

A CommandRouter implementation which uses Spring Cloud's DiscoveryClients to propagate its CommandMessage Routing Information, and to discover other Axon nodes and retrieve their Message Routing Information. It does so by utilizing the metadata contained in a ServiceInstance for storing the Message Routing Information in. Other nodes discovered through the DiscoveryClient system which do not contain any of the required Message Routing Information fields will be black listed, so not to perform any unneeded additional checks on that node.

Author:

Steven van Beelen

Field Summary

Fields

Modifier and Type	Field and Description
protected XStreamSerializer	serializer

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 its own membership as a CommandRouter and to create its own awareness of available nodes to send commands to in a ConsistentHash.
SpringCloudCommandRouter(org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient, RoutingStrategy routingStrategy, Predicate<org.springframework.cloud.client.ServiceInstance> serviceInstanceFilter) Initialize a CommandRouter with the given DiscoveryClient to update its own membership as a CommandRouter and to create its 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
protected SimpleMember<URI>	buildSimpleMember(org.springframework.cloud.client.ServiceInstance serviceInstance) Instantiate a SimpleMember of type URI based on the provided serviceInstance.
Optional<Member>	findDestination(CommandMessage<?> commandMessage) Returns the member instance to which the given message should be routed.
protected Optional<MessageRoutingInformation>	getMessageRoutingInformation(org.springframework.cloud.client.ServiceInstance serviceInstance) Retrieve the MessageRoutingInformation of the provided serviceInstance.
static boolean	serviceInstanceMetadataContainsMessageRoutingInformation(org.springframework.cloud.client.ServiceInstance serviceInstance) Boolean check if the metadata Map of the given ServiceInstance contains any of the expected message routing info keys.
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

Field Detail

serializer

protected final XStreamSerializer serializer

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 its own membership as a CommandRouter and to create its 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 its set of Commands it can handle to be added as meta data to this ServiceInstance. Uses a default Predicate<ServiceInstance> filter function to remove any ServiceInstance which miss message routing information key-value pairs in their metadata. This is thus the serviceInstanceMetadataContainsMessageRoutingInformation(ServiceInstance serviceInstance) function.

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 its 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 its own membership as a CommandRouter and to create its 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. Uses a default Predicate<ServiceInstance> filter function to remove any ServiceInstance which miss message routing information key-value pairs in their metadata. This is thus the serviceInstanceMetadataContainsMessageRoutingInformation(ServiceInstance serviceInstance) function.

Parameters:

discoveryClient - The DiscoveryClient used to discovery and notify other nodes

routingStrategy - The strategy for routing Commands to a Node

SpringCloudCommandRouter

public SpringCloudCommandRouter(org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient,
                                RoutingStrategy routingStrategy,
                                Predicate<org.springframework.cloud.client.ServiceInstance> serviceInstanceFilter)

Initialize a CommandRouter with the given DiscoveryClient to update its own membership as a CommandRouter and to create its 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. A Predicate<ServiceInstance> to filter a ServiceInstance from the membership update loop.

Parameters:

discoveryClient - The DiscoveryClient used to discovery and notify other nodes

routingStrategy - The strategy for routing Commands to a Node

serviceInstanceFilter - The Predicate<ServiceInstance> used to filter ServiceInstance from the update membership loop.

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)

buildSimpleMember

protected SimpleMember<URI> buildSimpleMember(org.springframework.cloud.client.ServiceInstance serviceInstance)

Instantiate a SimpleMember of type URI based on the provided serviceInstance. This SimpleMember is later used to send, for example, Command messages to.

Parameters:

serviceInstance - A ServiceInstance to build a SimpleMember for.

Returns:

A SimpleMember based on the contents of the provided serviceInstance.

getMessageRoutingInformation

protected Optional<MessageRoutingInformation> getMessageRoutingInformation(org.springframework.cloud.client.ServiceInstance serviceInstance)

Retrieve the MessageRoutingInformation of the provided serviceInstance. If the MessageRoutingInformation could not be found, an Optional.empty() will be returned. Otherwise the MessageRoutingInformation will be contained in the Optional.

Parameters:

serviceInstance - A ServiceInstance to retrieve MessageRoutingInformation from.

Returns:

an Optional of type MessageRoutingInformation, containing the corresponding MessageRoutingInformation for the given serviceInstance if it could be retrieved.

serviceInstanceMetadataContainsMessageRoutingInformation

public static boolean serviceInstanceMetadataContainsMessageRoutingInformation(org.springframework.cloud.client.ServiceInstance serviceInstance)

Boolean check if the metadata Map of the given ServiceInstance contains any of the expected message routing info keys.

Parameters:

serviceInstance - The ServiceInstance to check its metadata keys from

Returns:

true if the given serviceInstance contains all expected message routing info keys; false if one of the expected message routing info keys is missing.