Modifier and Type | Method and Description |
---|---|
RoutingStrategy |
RoutingStrategyAutoConfiguration.routingStrategy() |
Modifier and Type | Method and Description |
---|---|
JGroupsConnectorFactoryBean |
JGroupsAutoConfiguration.jgroupsConnectorFactoryBean(Serializer messageSerializer,
CommandBus localSegment,
RoutingStrategy routingStrategy,
ConsistentHashChangeListener consistentHashChangeListener) |
CommandRouter |
SpringCloudAutoConfiguration.springCloudCommandRouter(org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient,
org.springframework.cloud.client.serviceregistry.Registration localServiceInstance,
RoutingStrategy routingStrategy) |
SpringCloudHttpBackupCommandRouter |
SpringCloudAutoConfiguration.springCloudHttpBackupCommandRouter(org.springframework.cloud.client.discovery.DiscoveryClient discoveryClient,
org.springframework.cloud.client.serviceregistry.Registration localServiceInstance,
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. |
JGroupsConnector(CommandBus localSegment,
org.jgroups.JChannel channel,
String clusterName,
Serializer serializer,
RoutingStrategy routingStrategy,
ConsistentHashChangeListener consistentHashChangeListener)
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,
org.springframework.cloud.client.serviceregistry.Registration localServiceInstance,
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,
org.springframework.cloud.client.serviceregistry.Registration localServiceInstance,
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,
org.springframework.cloud.client.serviceregistry.Registration localServiceInstance,
RoutingStrategy routingStrategy,
Predicate<org.springframework.cloud.client.ServiceInstance> serviceInstanceFilter,
ConsistentHashChangeListener consistentHashChangeListener)
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,
org.springframework.cloud.client.serviceregistry.Registration localServiceInstance,
RoutingStrategy routingStrategy,
Predicate<org.springframework.cloud.client.ServiceInstance> serviceInstanceFilter,
ConsistentHashChangeListener consistentHashChangeListener,
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,
org.springframework.cloud.client.serviceregistry.Registration localServiceInstance,
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,
org.springframework.cloud.client.serviceregistry.Registration localServiceInstance,
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–2018. All rights reserved.