Package | Description |
---|---|
org.hornetq.api.core |
Core Messaging API.
|
org.hornetq.api.core.client |
Core Client Messaging API.
|
org.hornetq.core.client.impl | |
org.hornetq.core.cluster | |
org.hornetq.core.protocol.core.impl.wireformat | |
org.hornetq.core.remoting.impl.netty | |
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 |
---|---|
TransportConfiguration |
TopologyMemberImpl.getBackup() |
TransportConfiguration |
Topology.getBackupForConnector(Connector connector) |
TransportConfiguration |
ServerLocatorImpl.getClusterTransportConfiguration() |
TransportConfiguration |
ServerLocatorInternal.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 |
ServerLocatorImpl.setClusterTransportConfiguration(TransportConfiguration tc) |
void |
ServerLocatorInternal.setClusterTransportConfiguration(TransportConfiguration tc) |
void |
TopologyMemberImpl.setLive(TransportConfiguration param) |
Modifier and Type | Method and Description |
---|---|
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) |
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) |
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 | 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,
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 |
NettyConnection.getConnectorConfig() |
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 © 2016 JBoss, a division of Red Hat. All Rights Reserved.