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(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) |