Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
TransportConfiguration.newTransportConfig(String newName) |
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
|
boolean |
TransportConfiguration.isSameParams(TransportConfiguration that) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
TopologyMember.getBackup()
Returns the TransportConfiguration relative to the backup server if any.
|
TransportConfiguration |
ClientSessionFactory.getConnectorConfiguration()
Return the configuration used
|
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 |
ActiveMQClient.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 |
ActiveMQClient.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 |
ActiveMQClient.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 |
ClientSessionFactoryImpl.getConnectorConfiguration() |
TransportConfiguration[] |
ServerLocatorImpl.getInitialConnectors()
for tests only and not part of the public interface.
|
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 |
---|---|
void |
ServerLocatorImpl.notifyNodeUp(long uniqueEventID,
String nodeID,
String backupGroupName,
String scaleDownGroupName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
void |
ServerLocatorImpl.notifyNodeUp(long uniqueEventID,
String nodeID,
String backupGroupName,
String scaleDownGroupName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
void |
ServerLocatorInternal.notifyNodeUp(long uniqueEventID,
String nodeID,
String backupGroupName,
String scaleDownGroupName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
void |
ServerLocatorInternal.notifyNodeUp(long uniqueEventID,
String nodeID,
String backupGroupName,
String scaleDownGroupName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean last) |
Constructor and Description |
---|
ClientSessionFactoryImpl(ServerLocatorInternal serverLocator,
TransportConfiguration connectorConfig,
long callTimeout,
long callFailoverTimeout,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int reconnectAttempts,
Executor threadPool,
ScheduledExecutorService scheduledThreadPool,
List<Interceptor> incomingInterceptors,
List<Interceptor> outgoingInterceptors) |
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 backupGroupName,
String scaleDownGroupName,
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 |
---|---|
TransportConfiguration |
ActiveMQClientProtocolManagerFactory.adaptTransportConfiguration(TransportConfiguration tc) |
Modifier and Type | Method and Description |
---|---|
static Pair<TransportConfiguration,TransportConfiguration> |
BackwardsCompatibilityUtils.getTCPair(int clientIncrementingVersion,
TopologyMember member) |
static Pair<TransportConfiguration,TransportConfiguration> |
BackwardsCompatibilityUtils.getTCPair(int clientIncrementingVersion,
TopologyMember member) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
ActiveMQClientProtocolManagerFactory.adaptTransportConfiguration(TransportConfiguration tc) |
Modifier and Type | Field and Description |
---|---|
protected Pair<TransportConfiguration,TransportConfiguration> |
ClusterTopologyChangeMessage.pair |
protected Pair<TransportConfiguration,TransportConfiguration> |
ClusterTopologyChangeMessage.pair |
Modifier and Type | Method and Description |
---|---|
Pair<TransportConfiguration,TransportConfiguration> |
ClusterTopologyChangeMessage.getPair() |
Pair<TransportConfiguration,TransportConfiguration> |
ClusterTopologyChangeMessage.getPair() |
Modifier and Type | Method and Description |
---|---|
static boolean |
TransportConfigurationUtil.isSameHost(TransportConfiguration tc1,
TransportConfiguration tc2) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
NettyConnection.getConnectorConfig() |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
ClientProtocolManagerFactory.adaptTransportConfiguration(TransportConfiguration tc)
Adapt the transport configuration passed in parameter and return an adapted one that is suitable to use with ClientProtocolManager
created by this factory.
|
TransportConfiguration |
Connection.getConnectorConfig()
Generates a
TransportConfiguration to be used to connect to the same target this is
connected to. |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
ClientProtocolManagerFactory.adaptTransportConfiguration(TransportConfiguration tc)
Adapt the transport configuration passed in parameter and return an adapted one that is suitable to use with ClientProtocolManager
created by this factory.
|
Modifier and Type | Method and Description |
---|---|
void |
TopologyResponseHandler.notifyNodeUp(long uniqueEventID,
String backupGroupName,
String scaleDownGroupName,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean isLast) |
void |
TopologyResponseHandler.notifyNodeUp(long uniqueEventID,
String backupGroupName,
String scaleDownGroupName,
String nodeName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean isLast) |
Modifier and Type | Method and Description |
---|---|
static TransportConfiguration |
InVMTransportConfigurationSchema.createTransportConfiguration(URI uri,
Map<String,String> query,
String name,
String factoryName) |
Modifier and Type | Method and Description |
---|---|
static List<TransportConfiguration> |
TCPTransportConfigurationSchema.getTransportConfigurations(URI uri,
Map<String,String> query,
Set<String> allowableProperties,
String name,
String factoryName) |
protected List<TransportConfiguration> |
TCPTransportConfigurationSchema.internalNewObject(URI uri,
Map<String,String> query,
String name) |
protected List<TransportConfiguration> |
InVMTransportConfigurationSchema.internalNewObject(URI uri,
Map<String,String> query,
String name) |
Modifier and Type | Method and Description |
---|---|
protected URI |
TCPTransportConfigurationSchema.internalNewURI(List<TransportConfiguration> bean) |
protected URI |
InVMTransportConfigurationSchema.internalNewURI(List<TransportConfiguration> bean) |
Modifier and Type | Method and Description |
---|---|
static URI |
TCPServerLocatorSchema.getURI(String query,
TransportConfiguration[] staticConnectors) |
static URI |
InVMServerLocatorSchema.getUri(TransportConfiguration[] configurations) |
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.