Modifier and Type | Method and Description |
---|---|
RoutingStrategy |
RoutingStrategyAutoConfiguration.routingStrategy() |
Modifier and Type | Method and Description |
---|---|
JGroupsConnectorFactoryBean |
JGroupsAutoConfiguration.jgroupsConnectorFactoryBean(Serializer serializer,
CommandBus localSegment,
RoutingStrategy routingStrategy) |
CommandRouter |
SpringCloudAutoConfiguration.springCloudCommandRouter(org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient,
RoutingStrategy routingStrategy) |
CommandRouter |
SpringCloudAutoConfiguration.springCloudHttpBackupCommandRouter(org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient,
org.springframework.web.client.RestTemplate restTemplate,
RoutingStrategy routingStrategy) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRoutingStrategy
Abstract implementation of the RoutingStrategy interface that uses a policy to prescribe what happens when a routing
cannot be resolved.
|
class |
AnnotationRoutingStrategy
RoutingStrategy that expects an
TargetAggregateIdentifier
annotation on the command message's payload. |
class |
MetaDataRoutingStrategy
RoutingStrategy implementation that uses the value in the MetaData of a CommandMessage assigned to a given key.
|
Constructor and Description |
---|
JGroupsConnector(CommandBus localSegment,
org.jgroups.JChannel channel,
String clusterName,
Serializer serializer,
RoutingStrategy routingStrategy)
Initialize the connector using the given
localSegment to handle commands on the local node, and the given
channel to connect between nodes. |
Modifier and Type | Method and Description |
---|---|
protected JGroupsConnector |
JGroupsConnectorFactoryBean.instantiateConnector(CommandBus localSegment,
org.jgroups.JChannel channel,
String clusterName,
Serializer serializer,
RoutingStrategy routingStrategy) |
void |
JGroupsConnectorFactoryBean.setRoutingStrategy(RoutingStrategy routingStrategy)
Sets the
RoutingStrategy that the JGroupsConnector will use to determine to which endpoint a message
should be routed. |
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 |
SpringCloudHttpBackupCommandRouter(org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient,
RoutingStrategy routingStrategy,
Predicate<org.springframework.cloud.client.ServiceInstance> serviceInstanceFilter,
org.springframework.web.client.RestTemplate restTemplate,
String messageRoutingInformationEndpoint)
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 . |
SpringCloudHttpBackupCommandRouter(org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient,
RoutingStrategy routingStrategy,
org.springframework.web.client.RestTemplate restTemplate,
String messageRoutingInformationEndpoint)
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 . |
Copyright © 2010–2017. All rights reserved.