Package | Description |
---|---|
org.hornetq.api.jms |
API to create HornetQ JMS resources.
|
org.hornetq.jms.client |
Implementation of the JMS API.
|
org.hornetq.jms.management.impl | |
org.hornetq.jms.server | |
org.hornetq.jms.server.impl | |
org.hornetq.jms.server.management | |
org.hornetq.jms.server.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 |
---|---|
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.createConnectionFactoryWithHA(JMSFactoryType jmsFactoryType,
TransportConfiguration... initialServers)
Create a HornetQConnectionFactory which will receive 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
|
static HornetQConnectionFactory |
HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType jmsFactoryType,
TransportConfiguration... transportConfigurations)
Create a HornetQConnectionFactory which creates session factories using a static list of
transportConfigurations.
|
Modifier and Type | Class and Description |
---|---|
class |
HornetQJMSConnectionFactory
A class that represents a ConnectionFactory.
|
class |
HornetQQueueConnectionFactory
A class that represents a QueueConnectionFactory.
|
class |
HornetQTopicConnectionFactory
A class that represents a TopicConnectionFactory.
|
class |
HornetQXAConnectionFactory
A class that represents a XAConnectionFactory.
|
class |
HornetQXAQueueConnectionFactory
A class that represents a XAQueueConnectionFactory.
|
class |
HornetQXATopicConnectionFactory
A class that represents a XATopicConnectionFactory.
|
Modifier and Type | Method and Description |
---|---|
void |
HornetQConnection.setReference(HornetQConnectionFactory factory) |
Constructor and Description |
---|
JMSConnectionFactoryControlImpl(ConnectionFactoryConfiguration cfConfig,
HornetQConnectionFactory cf,
JMSServerManager jmsManager,
String name) |
Modifier and Type | Method and Description |
---|---|
HornetQConnectionFactory |
JMSServerManager.recreateCF(String name,
ConnectionFactoryConfiguration cf)
Call this method to have a CF rebound to JNDI and stored on the Journal
|
Modifier and Type | Method and Description |
---|---|
protected HornetQConnectionFactory |
JMSServerManagerImpl.internalCreateCFPOJO(ConnectionFactoryConfiguration cfConfig) |
HornetQConnectionFactory |
JMSServerManagerImpl.recreateCF(String name,
ConnectionFactoryConfiguration cf) |
Modifier and Type | Method and Description |
---|---|
void |
JMSManagementService.registerConnectionFactory(String name,
ConnectionFactoryConfiguration config,
HornetQConnectionFactory connectionFactory) |
Modifier and Type | Method and Description |
---|---|
void |
JMSManagementServiceImpl.registerConnectionFactory(String name,
ConnectionFactoryConfiguration cfConfig,
HornetQConnectionFactory connectionFactory) |
Modifier and Type | Method and Description |
---|---|
static XARecoveryConfig |
XARecoveryConfig.newConfig(HornetQConnectionFactory factory,
String userName,
String password) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.