Package | Description |
---|---|
org.hornetq.api.core |
Core Messaging API.
|
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.cluster | |
org.hornetq.core.config | |
org.hornetq.core.config.impl | |
org.hornetq.core.management.impl | |
org.hornetq.core.protocol.core.impl.wireformat | |
org.hornetq.core.remoting.impl.invm | |
org.hornetq.core.remoting.impl.netty | |
org.hornetq.core.server.cluster | |
org.hornetq.core.server.cluster.impl | |
org.hornetq.core.server.management | |
org.hornetq.core.server.management.impl | |
org.hornetq.jms.client |
Implementation of the JMS API.
|
org.hornetq.jms.management.impl | |
org.hornetq.jms.server.config.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
|
org.hornetq.spi.core.remoting |
Remoting SPI.
|
Modifier and Type | Method and Description |
---|---|
boolean |
TransportConfiguration.isEquivalent(TransportConfiguration otherConfig)
There's a case on ClusterConnections that we need to find an equivalent Connector
and we can't use a Netty Cluster Connection on an InVM ClusterConnection (inVM used on tests)
for that reason I need to test if the two instances of the TransportConfiguration are equivalent
while a test a connector against an acceptor
|
Modifier and Type | Method and Description |
---|---|
TransportConfiguration[] |
ServerLocator.getStaticTransportConfigurations()
Returns an array of TransportConfigurations representing the static list of live servers used when
creating this object
|
Modifier and Type | Method and Description |
---|---|
static ServerLocator |
HornetQClient.createServerLocator(boolean ha,
TransportConfiguration... transportConfigurations)
Create a ServerLocator which creates session factories using a static list of transportConfigurations, the ServerLocator is not updated automatically
as the cluster topology changes, and no HA backup information is propagated to the client
|
static ServerLocator |
HornetQClient.createServerLocatorWithHA(TransportConfiguration... initialServers)
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(TransportConfiguration... transportConfigurations)
Create a ServerLocator which creates session factories using a static list of transportConfigurations, the ServerLocator is not updated automatically
as the cluster topology changes, and no HA backup information is propagated to the client
|
ClientSessionFactory |
ServerLocator.createSessionFactory(TransportConfiguration transportConfiguration)
Create a ClientSessionFactory to a specific server.
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterTopologyListener.nodeUP(long eventUID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
void |
ClusterTopologyListener.nodeUP(long eventUID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
Modifier and Type | Method and Description |
---|---|
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(JMSFactoryType jmsFactoryType,
TransportConfiguration... transportConfigurations)
Create a HornetQConnectionFactory which creates session factories using a static list of transportConfigurations, the HornetQConnectionFactory is not updated automatically
as the cluster topology changes, and no HA backup information is propagated to the client
|
Modifier and Type | Method and Description |
---|---|
TransportConfiguration[] |
ConnectionFactoryControl.getStaticConnectors() |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
TopologyMember.getA() |
TransportConfiguration |
TopologyMember.getB() |
TransportConfiguration |
Topology.getBackupForConnector(TransportConfiguration connectorConfiguration) |
TransportConfiguration |
ServerLocatorInternal.getClusterTransportConfiguration() |
TransportConfiguration |
ServerLocatorImpl.getClusterTransportConfiguration() |
TransportConfiguration |
ClientSessionFactoryInternal.getConnectorConfiguration() |
TransportConfiguration |
ClientSessionFactoryImpl.getConnectorConfiguration() |
TransportConfiguration[] |
ServerLocatorImpl.getStaticTransportConfigurations() |
Modifier and Type | Method and Description |
---|---|
Pair<TransportConfiguration,TransportConfiguration> |
TopologyMember.getConnector() |
Pair<TransportConfiguration,TransportConfiguration> |
TopologyMember.getConnector() |
Modifier and Type | Method and Description |
---|---|
void |
ServerLocatorInternal.notifyNodeUp(long uniqueEventID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
void |
ServerLocatorInternal.notifyNodeUp(long uniqueEventID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
void |
ServerLocatorImpl.notifyNodeUp(long uniqueEventID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
void |
ServerLocatorImpl.notifyNodeUp(long uniqueEventID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
Constructor and Description |
---|
ClientSessionFactoryImpl(ServerLocatorInternal serverLocator,
TransportConfiguration connectorConfig,
long callTimeout,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
List<Interceptor> interceptors) |
ServerLocatorImpl(boolean useHA,
TransportConfiguration... transportConfigs)
Create a ServerLocatorImpl using a static list of live servers
|
ServerLocatorImpl(Topology topology,
boolean useHA,
TransportConfiguration... transportConfigs)
Create a ServerLocatorImpl using a static list of live servers
|
TopologyMember(TransportConfiguration a,
TransportConfiguration b) |
Constructor and Description |
---|
TopologyMember(Pair<TransportConfiguration,TransportConfiguration> connector) |
TopologyMember(Pair<TransportConfiguration,TransportConfiguration> connector) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
DiscoveryEntry.getConnector() |
Constructor and Description |
---|
DiscoveryEntry(String nodeID,
TransportConfiguration connector,
long lastUpdate) |
Modifier and Type | Method and Description |
---|---|
Set<TransportConfiguration> |
Configuration.getAcceptorConfigurations()
Returns the acceptors configured for this server.
|
Map<String,TransportConfiguration> |
Configuration.getConnectorConfigurations()
Returns the connectors configured for this server.
|
Modifier and Type | Method and Description |
---|---|
void |
Configuration.setAcceptorConfigurations(Set<TransportConfiguration> infos)
Sets the acceptors configured for this server.
|
void |
Configuration.setConnectorConfigurations(Map<String,TransportConfiguration> infos)
Sets the connectors configured for this server.
|
Modifier and Type | Field and Description |
---|---|
protected Set<TransportConfiguration> |
ConfigurationImpl.acceptorConfigs |
protected Map<String,TransportConfiguration> |
ConfigurationImpl.connectorConfigs |
Modifier and Type | Method and Description |
---|---|
Set<TransportConfiguration> |
ConfigurationImpl.getAcceptorConfigurations() |
Map<String,TransportConfiguration> |
ConfigurationImpl.getConnectorConfigurations() |
Modifier and Type | Method and Description |
---|---|
void |
ConfigurationImpl.setAcceptorConfigurations(Set<TransportConfiguration> infos) |
void |
ConfigurationImpl.setConnectorConfigurations(Map<String,TransportConfiguration> infos) |
Constructor and Description |
---|
AcceptorControlImpl(Acceptor acceptor,
StorageManager storageManager,
TransportConfiguration configuration) |
Modifier and Type | Field and Description |
---|---|
protected Pair<TransportConfiguration,TransportConfiguration> |
ClusterTopologyChangeMessage.pair |
protected Pair<TransportConfiguration,TransportConfiguration> |
ClusterTopologyChangeMessage.pair |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
NodeAnnounceMessage.getBackupConnector() |
TransportConfiguration |
NodeAnnounceMessage.getConnector() |
Modifier and Type | Method and Description |
---|---|
Pair<TransportConfiguration,TransportConfiguration> |
ClusterTopologyChangeMessage.getPair() |
Pair<TransportConfiguration,TransportConfiguration> |
ClusterTopologyChangeMessage.getPair() |
Constructor and Description |
---|
NodeAnnounceMessage(long currentEventID,
String nodeID,
boolean backup,
TransportConfiguration tc,
TransportConfiguration backupConnector) |
Constructor and Description |
---|
ClusterTopologyChangeMessage_V2(long uniqueEventID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean last) |
ClusterTopologyChangeMessage_V2(long uniqueEventID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean last) |
ClusterTopologyChangeMessage(String nodeID,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean last) |
ClusterTopologyChangeMessage(String nodeID,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean last) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
InVMConnection.getConnectorConfig()
Generates a
TransportConfiguration to be use to connect to the
same target this is connect to |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
NettyConnection.getConnectorConfig()
Generates a
TransportConfiguration to be use to connect to the
same target this is connect to |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
ClusterConnection.getConnector() |
Modifier and Type | Method and Description |
---|---|
void |
BroadcastGroup.addConnector(TransportConfiguration tcConfig) |
ClusterConnection |
ClusterManager.getDefaultConnection(TransportConfiguration acceptorConfig)
Return the default ClusterConnection to be used case it's not defined by the acceptor
|
void |
BroadcastGroup.removeConnector(TransportConfiguration tcConfig) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterConnection.nodeAnnounced(long eventUID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
void |
ClusterConnection.nodeAnnounced(long eventUID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
ClusterConnectionImpl.getConnector() |
Modifier and Type | Method and Description |
---|---|
void |
BroadcastGroupImpl.addConnector(TransportConfiguration tcConfig) |
ClusterConnection |
ClusterManagerImpl.getDefaultConnection(TransportConfiguration acceptorConfig) |
void |
BroadcastGroupImpl.removeConnector(TransportConfiguration tcConfig) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterConnectionImpl.nodeAnnounced(long uniqueEventID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
void |
ClusterConnectionImpl.nodeAnnounced(long uniqueEventID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
void |
ClusterConnectionImpl.nodeUP(long eventUID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
void |
ClusterConnectionImpl.nodeUP(long eventUID,
String nodeID,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
Constructor and Description |
---|
ClusterConnectionBridge(ClusterConnection clusterConnection,
ClusterManagerInternal clusterManager,
ServerLocatorInternal targetLocator,
ServerLocatorInternal discoveryLocator,
int reconnectAttempts,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
long targetNodeEventUID,
String targetNodeID,
SimpleString name,
Queue queue,
Executor executor,
SimpleString filterString,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
boolean activated,
StorageManager storageManager,
SimpleString managementAddress,
SimpleString managementNotificationAddress,
MessageFlowRecord flowRecord,
TransportConfiguration connector) |
ClusterConnectionImpl(ClusterManagerImpl 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,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
UUID nodeUUID,
boolean backup,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly) |
ClusterConnectionImpl(ClusterManagerInternal manager,
TransportConfiguration[] tcConfigs,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
long callTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
UUID nodeUUID,
boolean backup,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly) |
ClusterConnectionImpl(ClusterManagerInternal manager,
TransportConfiguration[] tcConfigs,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
long callTimeout,
boolean useDuplicateDetection,
boolean routeWhenNoConsumers,
int confirmationWindowSize,
ExecutorFactory executorFactory,
HornetQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
UUID nodeUUID,
boolean backup,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly) |
Modifier and Type | Method and Description |
---|---|
void |
ManagementService.registerAcceptor(Acceptor acceptor,
TransportConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
ManagementServiceImpl.registerAcceptor(Acceptor acceptor,
TransportConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration[] |
HornetQConnectionFactory.getStaticConnectors() |
Constructor and Description |
---|
HornetQConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
HornetQJMSConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
HornetQQueueConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
HornetQTopicConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
HornetQXAConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
HornetQXAQueueConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
HornetQXATopicConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration[] |
JMSConnectionFactoryControlImpl.getStaticConnectors() |
Modifier and Type | Method and Description |
---|---|
static TransportConfiguration |
TransportConfigurationEncodingSupport.decode(HornetQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
static List<Pair<TransportConfiguration,TransportConfiguration>> |
TransportConfigurationEncodingSupport.decodeConfigs(HornetQBuffer buffer) |
static List<Pair<TransportConfiguration,TransportConfiguration>> |
TransportConfigurationEncodingSupport.decodeConfigs(HornetQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
static void |
TransportConfigurationEncodingSupport.encode(HornetQBuffer buffer,
TransportConfiguration config) |
static int |
TransportConfigurationEncodingSupport.getEncodeSize(TransportConfiguration config) |
Modifier and Type | Method and Description |
---|---|
static void |
TransportConfigurationEncodingSupport.encodeConfigs(HornetQBuffer buffer,
List<Pair<TransportConfiguration,TransportConfiguration>> configs) |
static void |
TransportConfigurationEncodingSupport.encodeConfigs(HornetQBuffer buffer,
List<Pair<TransportConfiguration,TransportConfiguration>> configs) |
static int |
TransportConfigurationEncodingSupport.getEncodeSize(List<Pair<TransportConfiguration,TransportConfiguration>> configs) |
static int |
TransportConfigurationEncodingSupport.getEncodeSize(List<Pair<TransportConfiguration,TransportConfiguration>> configs) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration[] |
XARecoveryConfig.getTransportConfig() |
Modifier and Type | Method and Description |
---|---|
void |
HornetQRecoveryRegistry.nodeUp(String nodeID,
Pair<TransportConfiguration,TransportConfiguration> networkConfiguration,
String username,
String password) |
void |
HornetQRecoveryRegistry.nodeUp(String nodeID,
Pair<TransportConfiguration,TransportConfiguration> networkConfiguration,
String username,
String password) |
Constructor and Description |
---|
XARecoveryConfig(boolean ha,
TransportConfiguration[] transportConfiguration,
String username,
String password) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
Connection.getConnectorConfig()
Generates a
TransportConfiguration to be use to connect to the
same target this is connect to |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.