Modifier and Type | Method and Description |
---|---|
DiscoveryGroupConfiguration |
DiscoveryGroupConfiguration.setBroadcastEndpointFactory(BroadcastEndpointFactory endpointFactory) |
DiscoveryGroupConfiguration |
DiscoveryGroupConfiguration.setDiscoveryInitialWaitTimeout(long discoveryInitialWaitTimeout) |
DiscoveryGroupConfiguration |
DiscoveryGroupConfiguration.setName(String name) |
DiscoveryGroupConfiguration |
DiscoveryGroupConfiguration.setRefreshTimeout(long refreshTimeout) |
Modifier and Type | Method and Description |
---|---|
DiscoveryGroupConfiguration |
ServerLocator.getDiscoveryGroupConfiguration()
The discovery group configuration
|
Modifier and Type | Method and Description |
---|---|
static ServerLocator |
ActiveMQClient.createServerLocator(boolean ha,
DiscoveryGroupConfiguration groupConfiguration)
Create a ServerLocator which creates session factories from a set of live servers, no HA
backup information is propagated to the client The UDP address and port are used to listen for
live servers in the cluster
|
static ServerLocator |
ActiveMQClient.createServerLocatorWithHA(DiscoveryGroupConfiguration groupConfiguration)
Create a ServerLocator which will receive cluster topology updates from the cluster as servers
leave or join and new backups are appointed or removed.
|
static ServerLocator |
ActiveMQClient.createServerLocatorWithoutHA(DiscoveryGroupConfiguration groupConfiguration)
Create a ServerLocator which creates session factories from a set of live servers, no HA
backup information is propagated to the client
|
Modifier and Type | Method and Description |
---|---|
abstract ActiveMQConnectionFactory |
JMSFactoryType.createConnectionFactoryWithHA(DiscoveryGroupConfiguration groupConfiguration)
Creates an ActiveMQConnectionFactory that receives cluster topology updates from the cluster as
servers leave or join and new backups are appointed or removed.
|
static ActiveMQConnectionFactory |
ActiveMQJMSClient.createConnectionFactoryWithHA(DiscoveryGroupConfiguration groupConfiguration,
JMSFactoryType jmsFactoryType)
Creates an ActiveMQConnectionFactory that receives cluster topology updates from the cluster as
servers leave or join and new backups are appointed or removed.
|
abstract ActiveMQConnectionFactory |
JMSFactoryType.createConnectionFactoryWithoutHA(DiscoveryGroupConfiguration groupConfiguration)
Create an ActiveMQConnectionFactory which creates session factories from a set of live servers, no HA backup information is propagated to the client
|
static ActiveMQConnectionFactory |
ActiveMQJMSClient.createConnectionFactoryWithoutHA(DiscoveryGroupConfiguration groupConfiguration,
JMSFactoryType jmsFactoryType)
Create an ActiveMQConnectionFactory which creates session factories from a set of live servers, no HA backup information is propagated to the client
The UDP address and port are used to listen for live servers in the cluster
|
Modifier and Type | Method and Description |
---|---|
DiscoveryGroupConfiguration |
ServerLocatorImpl.getDiscoveryGroupConfiguration() |
Constructor and Description |
---|
ServerLocatorImpl(boolean useHA,
DiscoveryGroupConfiguration groupConfiguration)
Create a ServerLocatorImpl using UDP discovery to lookup cluster
|
ServerLocatorImpl(Topology topology,
boolean useHA,
DiscoveryGroupConfiguration groupConfiguration)
Create a ServerLocatorImpl using UDP discovery to lookup cluster
|
Modifier and Type | Method and Description |
---|---|
DiscoveryGroupConfiguration |
ClusterConnectionConfiguration.getDiscoveryGroupConfiguration(Configuration configuration)
This method will return the proper discovery configuration from the main configuration
|
Modifier and Type | Method and Description |
---|---|
Map<String,DiscoveryGroupConfiguration> |
Configuration.getDiscoveryGroupConfigurations()
Returns the discovery groups configured for this server.
|
Modifier and Type | Method and Description |
---|---|
Configuration |
Configuration.addDiscoveryGroupConfiguration(String key,
DiscoveryGroupConfiguration discoveryGroupConfiguration) |
Modifier and Type | Method and Description |
---|---|
Configuration |
Configuration.setDiscoveryGroupConfigurations(Map<String,DiscoveryGroupConfiguration> configs)
Sets the discovery groups configured for this server.
|
Modifier and Type | Field and Description |
---|---|
protected Map<String,DiscoveryGroupConfiguration> |
ConfigurationImpl.discoveryGroupConfigurations |
Modifier and Type | Method and Description |
---|---|
Map<String,DiscoveryGroupConfiguration> |
ConfigurationImpl.getDiscoveryGroupConfigurations() |
Modifier and Type | Method and Description |
---|---|
ConfigurationImpl |
ConfigurationImpl.addDiscoveryGroupConfiguration(String key,
DiscoveryGroupConfiguration discoveryGroupConfiguration) |
Modifier and Type | Method and Description |
---|---|
ConfigurationImpl |
ConfigurationImpl.setDiscoveryGroupConfigurations(Map<String,DiscoveryGroupConfiguration> discoveryGroupConfigurations) |
Modifier and Type | Method and Description |
---|---|
ActiveMQException |
ActiveMQMessageBundle.noDiscoveryGroupFound(DiscoveryGroupConfiguration dg) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterController.addClusterConnection(SimpleString name,
DiscoveryGroupConfiguration dg,
ClusterConnectionConfiguration config)
add a locator for a cluster connection.
|
Constructor and Description |
---|
ClusterConnectionImpl(ClusterManager manager,
DiscoveryGroupConfiguration dg,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int initialConnectAttempts,
int reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
MessageLoadBalancingType messageLoadBalancingType,
int confirmationWindowSize,
int producerWindowSize,
ExecutorFactory executorFactory,
ActiveMQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly,
long clusterNotificationInterval,
int clusterNotificationAttempts) |
Modifier and Type | Method and Description |
---|---|
DiscoveryGroupConfiguration |
ActiveMQConnectionFactory.getDiscoveryGroupConfiguration() |
Constructor and Description |
---|
ActiveMQConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
ActiveMQJMSConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
ActiveMQQueueConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
ActiveMQTopicConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
ActiveMQXAConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
ActiveMQXAQueueConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
ActiveMQXATopicConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
Modifier and Type | Method and Description |
---|---|
DiscoveryGroupConfiguration |
XARecoveryConfig.getDiscoveryConfiguration() |
Constructor and Description |
---|
XARecoveryConfig(boolean ha,
DiscoveryGroupConfiguration discoveryConfiguration,
String username,
String password,
Map<String,String> properties) |
XARecoveryConfig(boolean ha,
DiscoveryGroupConfiguration discoveryConfiguration,
String username,
String password,
Map<String,String> properties,
ClientProtocolManagerFactory clientProtocolManager) |
Modifier and Type | Method and Description |
---|---|
static DiscoveryGroupConfiguration |
JGroupsServerLocatorSchema.getDiscoveryGroupConfiguration(URI uri,
Map<String,String> query,
String name) |
static DiscoveryGroupConfiguration |
UDPServerLocatorSchema.getDiscoveryGroupConfiguration(URI uri,
Map<String,String> query,
String host,
int port,
String name) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.