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 | |
org.hornetq.core.server.cluster | |
org.hornetq.core.server.cluster.impl | |
org.hornetq.core.server.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 |
TopologyMember.getBackup()
Returns the TransportConfiguration relative to the backup server if any.
|
TransportConfiguration |
TopologyMember.getLive() |
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)
Creates a
ClientSessionFactory to a specific server. |
ClientSessionFactory |
ServerLocator.createSessionFactory(TransportConfiguration transportConfiguration,
int reconnectAttempts,
boolean failoverOnInitialConnection)
Creates a
ClientSessionFactory to a specific server. |
boolean |
TopologyMember.isMember(TransportConfiguration configuration)
Returns true if this configuration is the target of this remoting connection
|
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.
|
Modifier and Type | Method and Description |
---|---|
TransportConfiguration[] |
ConnectionFactoryControl.getStaticConnectors() |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
TopologyMemberImpl.getBackup() |
TransportConfiguration |
Topology.getBackupForConnector(Connector connector) |
TransportConfiguration |
ServerLocatorInternal.getClusterTransportConfiguration() |
TransportConfiguration |
ServerLocatorImpl.getClusterTransportConfiguration() |
TransportConfiguration |
ClientSessionFactoryInternal.getConnectorConfiguration() |
TransportConfiguration |
ClientSessionFactoryImpl.getConnectorConfiguration() |
TransportConfiguration |
TopologyMemberImpl.getLive() |
TransportConfiguration[] |
ServerLocatorImpl.getStaticTransportConfigurations() |
Modifier and Type | Method and Description |
---|---|
Pair<TransportConfiguration,TransportConfiguration> |
TopologyMemberImpl.getConnector() |
Pair<TransportConfiguration,TransportConfiguration> |
TopologyMemberImpl.getConnector() |
Modifier and Type | Method and Description |
---|---|
ClientSessionFactory |
ServerLocatorImpl.createSessionFactory(TransportConfiguration transportConfiguration) |
ClientSessionFactory |
ServerLocatorImpl.createSessionFactory(TransportConfiguration transportConfiguration,
int reconnectAttempts,
boolean failoverOnInitialConnection) |
TopologyMemberImpl |
Topology.getMember(TransportConfiguration configuration) |
boolean |
TopologyMemberImpl.isMember(TransportConfiguration configuration) |
void |
ClientSessionFactoryInternal.sendNodeAnnounce(long currentEventID,
String nodeID,
String nodeName,
boolean isBackup,
TransportConfiguration config,
TransportConfiguration backupConfig) |
void |
ClientSessionFactoryImpl.sendNodeAnnounce(long currentEventID,
String nodeID,
String nodeName,
boolean isBackup,
TransportConfiguration config,
TransportConfiguration backupConfig) |
void |
TopologyMemberImpl.setBackup(TransportConfiguration param) |
void |
ClientSessionFactoryInternal.setBackupConnector(TransportConfiguration live,
TransportConfiguration backUp) |
void |
ClientSessionFactoryImpl.setBackupConnector(TransportConfiguration live,
TransportConfiguration backUp) |
void |
ServerLocatorInternal.setClusterTransportConfiguration(TransportConfiguration tc) |
void |
ServerLocatorImpl.setClusterTransportConfiguration(TransportConfiguration tc) |
void |
TopologyMemberImpl.setLive(TransportConfiguration param) |
Modifier and Type | Method and Description |
---|---|
void |
ServerLocatorInternal.notifyNodeUp(long uniqueEventID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
void |
ServerLocatorInternal.notifyNodeUp(long uniqueEventID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
void |
ServerLocatorImpl.notifyNodeUp(long uniqueEventID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
void |
ServerLocatorImpl.notifyNodeUp(long uniqueEventID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
Constructor and Description |
---|
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
|
TopologyMemberImpl(String nodeId,
String nodeName,
TransportConfiguration a,
TransportConfiguration b) |
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 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 |
BackupRegistrationMessage.getConnector() |
TransportConfiguration |
NodeAnnounceMessage.getConnector() |
Modifier and Type | Method and Description |
---|---|
Pair<TransportConfiguration,TransportConfiguration> |
ClusterTopologyChangeMessage.getPair() |
Pair<TransportConfiguration,TransportConfiguration> |
ClusterTopologyChangeMessage.getPair() |
Constructor and Description |
---|
BackupRegistrationMessage(TransportConfiguration tc,
String user,
String password,
boolean backupWantsFailBack) |
NodeAnnounceMessage(long currentEventID,
String nodeID,
String nodeName,
boolean backup,
TransportConfiguration tc,
TransportConfiguration backupConnector) |
Constructor and Description |
---|
ClusterTopologyChangeMessage_V2(long uniqueEventID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean last) |
ClusterTopologyChangeMessage_V2(long uniqueEventID,
String nodeID,
String nodeName,
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() |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
NettyConnection.getConnectorConfig() |
Modifier and Type | Method and Description |
---|---|
abstract Pair<TransportConfiguration,TransportConfiguration> |
LiveNodeLocator.getLiveConfiguration()
Returns the current connector
|
abstract Pair<TransportConfiguration,TransportConfiguration> |
LiveNodeLocator.getLiveConfiguration()
Returns the current connector
|
Modifier and Type | Method and Description |
---|---|
void |
HornetQServer.startReplication(CoreRemotingConnection rc,
ClusterConnection clusterConnection,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean failBackRequest)
Starts replication.
|
void |
HornetQServer.startReplication(CoreRemotingConnection rc,
ClusterConnection clusterConnection,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean failBackRequest)
Starts replication.
|
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,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
void |
ClusterConnection.nodeAnnounced(long eventUID,
String nodeID,
String nodeName,
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) |
void |
BroadcastGroupImpl.removeConnector(TransportConfiguration tcConfig) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterConnectionImpl.nodeAnnounced(long uniqueEventID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
void |
ClusterConnectionImpl.nodeAnnounced(long uniqueEventID,
String nodeID,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
Constructor and Description |
---|
ClusterConnectionBridge(ClusterConnection clusterConnection,
ClusterManager 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,
Filter 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(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) |
ClusterConnectionImpl(ClusterManager manager,
TransportConfiguration[] staticTranspConfigs,
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) |
ClusterConnectionImpl(ClusterManager manager,
TransportConfiguration[] staticTranspConfigs,
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 |
---|---|
Pair<TransportConfiguration,TransportConfiguration> |
NamedLiveNodeLocator.getLiveConfiguration() |
Pair<TransportConfiguration,TransportConfiguration> |
NamedLiveNodeLocator.getLiveConfiguration() |
Pair<TransportConfiguration,TransportConfiguration> |
AnyLiveNodeLocator.getLiveConfiguration() |
Pair<TransportConfiguration,TransportConfiguration> |
AnyLiveNodeLocator.getLiveConfiguration() |
Modifier and Type | Method and Description |
---|---|
void |
HornetQServerImpl.startReplication(CoreRemotingConnection rc,
ClusterConnection clusterConnection,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean isFailBackRequest) |
void |
HornetQServerImpl.startReplication(CoreRemotingConnection rc,
ClusterConnection clusterConnection,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean isFailBackRequest) |
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 used to connect to the same target this is
connected to. |
Copyright © 2018 JBoss by Red Hat. All rights reserved.