| Modifier and Type | Method and Description |
|---|---|
ClusterConnectionConfiguration |
Configuration.addClusterConfiguration(String name,
String uri) |
static ClusterConnectionConfiguration |
ConfigurationUtils.getReplicationClusterConfiguration(Configuration conf,
String replicationCluster) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setAddress(String address) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setAllowDirectConnectionsOnly(boolean allowDirectConnectionsOnly) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setCallFailoverTimeout(long callFailoverTimeout) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setCallTimeout(long callTimeout) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setClientFailureCheckPeriod(long clientFailureCheckPeriod) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setClusterNotificationAttempts(int clusterNotificationAttempts) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setClusterNotificationInterval(long clusterNotificationInterval) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setCompositeMembers(org.apache.activemq.artemis.utils.uri.URISupport.CompositeData members) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setConfirmationWindowSize(int confirmationWindowSize) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setConnectionTTL(long connectionTTL) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setConnectorName(String connectorName) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setDiscoveryGroupName(String discoveryGroupName) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setDuplicateDetection(boolean duplicateDetection) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setInitialConnectAttempts(int initialConnectAttempts) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setMaxHops(int maxHops) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setMaxRetryInterval(long maxRetryInterval) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setMessageLoadBalancingType(MessageLoadBalancingType messageLoadBalancingType) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setMinLargeMessageSize(int minLargeMessageSize) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setName(String name) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setProducerWindowSize(int producerWindowSize) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setReconnectAttempts(int reconnectAttempts) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setRetryInterval(long retryInterval) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setRetryIntervalMultiplier(double retryIntervalMultiplier) |
ClusterConnectionConfiguration |
ClusterConnectionConfiguration.setStaticConnectors(List<String> staticConnectors) |
| Modifier and Type | Method and Description |
|---|---|
List<ClusterConnectionConfiguration> |
Configuration.getClusterConfigurations()
Returns the cluster connections configured for this server.
|
| Modifier and Type | Method and Description |
|---|---|
Configuration |
Configuration.addClusterConfiguration(ClusterConnectionConfiguration config) |
| Modifier and Type | Method and Description |
|---|---|
Configuration |
Configuration.setClusterConfigurations(List<ClusterConnectionConfiguration> configs)
Sets the cluster connections configured for this server.
|
| Modifier and Type | Field and Description |
|---|---|
protected List<ClusterConnectionConfiguration> |
ConfigurationImpl.clusterConfigurations |
| Modifier and Type | Method and Description |
|---|---|
ClusterConnectionConfiguration |
ConfigurationImpl.addClusterConfiguration(String name,
String uri) |
| Modifier and Type | Method and Description |
|---|---|
List<ClusterConnectionConfiguration> |
ConfigurationImpl.getClusterConfigurations() |
| Modifier and Type | Method and Description |
|---|---|
ConfigurationImpl |
ConfigurationImpl.addClusterConfiguration(ClusterConnectionConfiguration config) |
| Modifier and Type | Method and Description |
|---|---|
ConfigurationImpl |
ConfigurationImpl.setClusterConfigurations(List<ClusterConnectionConfiguration> configs) |
| Constructor and Description |
|---|
ClusterConnectionControlImpl(ClusterConnection clusterConnection,
StorageManager storageManager,
ClusterConnectionConfiguration configuration) |
| Modifier and Type | Method and Description |
|---|---|
void |
ClusterController.addClusterConnection(org.apache.activemq.artemis.api.core.SimpleString name,
org.apache.activemq.artemis.api.core.DiscoveryGroupConfiguration dg,
ClusterConnectionConfiguration config)
add a locator for a cluster connection.
|
void |
ClusterController.addClusterConnection(org.apache.activemq.artemis.api.core.SimpleString name,
org.apache.activemq.artemis.api.core.TransportConfiguration[] tcConfigs,
ClusterConnectionConfiguration config)
add a locator for a cluster connection.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ManagementService.registerCluster(ClusterConnection cluster,
ClusterConnectionConfiguration configuration) |
| Modifier and Type | Method and Description |
|---|---|
void |
ManagementServiceImpl.registerCluster(ClusterConnection cluster,
ClusterConnectionConfiguration configuration) |
| Modifier and Type | Method and Description |
|---|---|
protected ClusterConnectionConfiguration |
ClusterConnectionStaticSchema.internalNewObject(URI uri,
Map<String,String> query,
String param) |
| Modifier and Type | Method and Description |
|---|---|
protected URI |
ClusterConnectionStaticSchema.internalNewURI(ClusterConnectionConfiguration bean) |
void |
ClusterConnectionStaticSchema.populateObject(URI uri,
ClusterConnectionConfiguration bean) |
void |
ClusterConnectionMulticastSchema.populateObject(URI uri,
ClusterConnectionConfiguration bean) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.