Package | Description |
---|---|
org.hornetq.api.core.client |
Core Client Messaging API.
|
org.hornetq.api.jms |
API to create HornetQ JMS resources.
|
org.hornetq.api.jms.management |
Management API for HornetQ JMS resources.
|
org.hornetq.core.client.impl | |
org.hornetq.core.config | |
org.hornetq.core.config.impl | |
org.hornetq.core.server | |
org.hornetq.core.server.cluster.impl | |
org.hornetq.jms.client |
Implementation of the JMS API.
|
org.hornetq.jms.management.impl | |
org.hornetq.jms.server.recovery |
This package is used to locate resources and connectors along the cluster set
I - JCA Connection Factories or InBound MDBs will call HornetQRegistryBase::register(XARecoveryConfig)
II - For each XARecoveryConfig the RegistryBase will instantiate a ResourceDiscoveryUnit which will
connect using that configuration and inform the Registry of any topology members
III - For each topology member found on the DiscoveryUnits, the RegistryBase will registry a HornetQResourceRecovery
that will exist per server
|
Modifier and Type | Method and Description |
---|---|
DiscoveryGroupConfiguration |
ServerLocator.getDiscoveryGroupConfiguration()
The discovery group configuration
|
Modifier and Type | Method and Description |
---|---|
static ServerLocator |
HornetQClient.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 |
HornetQClient.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 |
HornetQClient.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 |
---|---|
static HornetQConnectionFactory |
HornetQJMSClient.createConnectionFactoryWithHA(DiscoveryGroupConfiguration groupConfiguration,
JMSFactoryType jmsFactoryType)
Creates a HornetQConnectionFactory that receives cluster topology updates from the cluster as
servers leave or join and new backups are appointed or removed.
|
static HornetQConnectionFactory |
HornetQJMSClient.createConnectionFactoryWithoutHA(DiscoveryGroupConfiguration groupConfiguration,
JMSFactoryType jmsFactoryType)
Create a HornetQConnectionFactory 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 |
ConnectionFactoryControl.getDiscoveryGroupConfiguration()
get the discovery group configuration
|
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 |
---|---|
Map<String,DiscoveryGroupConfiguration> |
Configuration.getDiscoveryGroupConfigurations()
Returns the discovery groups configured for this server.
|
Modifier and Type | Method and Description |
---|---|
void |
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 |
---|---|
void |
ConfigurationImpl.setDiscoveryGroupConfigurations(Map<String,DiscoveryGroupConfiguration> discoveryGroupConfigurations) |
Modifier and Type | Method and Description |
---|---|
HornetQException |
HornetQMessageBundle.noDiscoveryGroupFound(DiscoveryGroupConfiguration dg) |
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 reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
ExecutorService threadPool,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
boolean backup,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly,
long clusterNotificationInterval,
int clusterNotificationAttempts) |
Modifier and Type | Method and Description |
---|---|
DiscoveryGroupConfiguration |
HornetQConnectionFactory.getDiscoveryGroupConfiguration() |
Constructor and Description |
---|
HornetQConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
HornetQJMSConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
HornetQQueueConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
HornetQTopicConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
HornetQXAConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
HornetQXAQueueConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
HornetQXATopicConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
Modifier and Type | Method and Description |
---|---|
DiscoveryGroupConfiguration |
JMSConnectionFactoryControlImpl.getDiscoveryGroupConfiguration() |
Modifier and Type | Method and Description |
---|---|
DiscoveryGroupConfiguration |
XARecoveryConfig.getDiscoveryConfiguration() |
Constructor and Description |
---|
XARecoveryConfig(boolean ha,
DiscoveryGroupConfiguration discoveryConfiguration,
String username,
String password) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.