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 |
---|---|
static ActiveMQConnectionFactory |
ActiveMQJMSClient.createConnectionFactoryWithHA(JMSFactoryType jmsFactoryType,
TransportConfiguration... initialServers)
Create an ActiveMQConnectionFactory which will receive cluster topology updates from the cluster
as servers leave or join and new backups are appointed or removed.
|
abstract ActiveMQConnectionFactory |
JMSFactoryType.createConnectionFactoryWithHA(TransportConfiguration... initialServers)
Create an ActiveMQConnectionFactory which will receive cluster topology updates from the cluster
as servers leave or join and new backups are appointed or removed.
|
static ActiveMQConnectionFactory |
ActiveMQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType jmsFactoryType,
TransportConfiguration... transportConfigurations)
Create an ActiveMQConnectionFactory which creates session factories using a static list of
transportConfigurations.
|
abstract ActiveMQConnectionFactory |
JMSFactoryType.createConnectionFactoryWithoutHA(TransportConfiguration... transportConfigurations)
Create an ActiveMQConnectionFactory which creates session factories using a static list of
transportConfigurations.
|
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
TopologyMemberImpl.getBackup() |
TransportConfiguration |
Topology.getBackupForConnector(Connector connector) |
TransportConfiguration |
ServerLocatorInternal.getClusterTransportConfiguration() |
TransportConfiguration |
ServerLocatorImpl.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 |
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) |
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) |
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 |
ClusterConnectionConfiguration.getTransportConfiguration(Configuration configuration) |
TransportConfiguration[] |
ClusterConnectionConfiguration.getTransportConfigurations(Configuration configuration)
This method will match the configuration and return the proper TransportConfiguration for the Configuration
|
TransportConfiguration[] |
Configuration.getTransportConfigurations(List<String> connectorNames) |
TransportConfiguration[] |
Configuration.getTransportConfigurations(String... connectorNames) |
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.
|
static List<TransportConfiguration> |
ConfigurationUtils.parseAcceptorURI(String name,
String uri) |
static List<TransportConfiguration> |
ConfigurationUtils.parseAcceptorURI(String name,
URI uri) |
static List<TransportConfiguration> |
ConfigurationUtils.parseConnectorURI(String name,
String uri) |
static List<TransportConfiguration> |
ConfigurationUtils.parseConnectorURI(String name,
URI uri) |
Modifier and Type | Method and Description |
---|---|
Configuration |
Configuration.addAcceptorConfiguration(TransportConfiguration infos) |
Configuration |
Configuration.addConnectorConfiguration(String key,
TransportConfiguration info) |
Modifier and Type | Method and Description |
---|---|
Configuration |
Configuration.setAcceptorConfigurations(Set<TransportConfiguration> infos)
Sets the acceptors configured for this server.
|
Configuration |
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 |
---|---|
TransportConfiguration[] |
ConfigurationImpl.getTransportConfigurations(List<String> connectorNames) |
TransportConfiguration[] |
ConfigurationImpl.getTransportConfigurations(String... connectorNames) |
Modifier and Type | Method and Description |
---|---|
Set<TransportConfiguration> |
ConfigurationImpl.getAcceptorConfigurations() |
Map<String,TransportConfiguration> |
ConfigurationImpl.getConnectorConfigurations() |
Modifier and Type | Method and Description |
---|---|
ConfigurationImpl |
ConfigurationImpl.addAcceptorConfiguration(TransportConfiguration infos) |
ConfigurationImpl |
ConfigurationImpl.addConnectorConfiguration(String key,
TransportConfiguration info) |
Modifier and Type | Method and Description |
---|---|
ConfigurationImpl |
ConfigurationImpl.setAcceptorConfigurations(Set<TransportConfiguration> infos) |
ConfigurationImpl |
ConfigurationImpl.setConnectorConfigurations(Map<String,TransportConfiguration> infos) |
Constructor and Description |
---|
AcceptorControlImpl(Acceptor acceptor,
StorageManager storageManager,
TransportConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
ActiveMQClientProtocolManagerFactory.adaptTransportConfiguration(TransportConfiguration tc) |
Modifier and Type | Method and Description |
---|---|
static Pair<TransportConfiguration,TransportConfiguration> |
BackwardsCompatibilityUtils.checkTCPPairConversion(int clientIncrementingVersion,
TopologyMember member) |
static Pair<TransportConfiguration,TransportConfiguration> |
BackwardsCompatibilityUtils.checkTCPPairConversion(int clientIncrementingVersion,
TopologyMember member) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
ActiveMQClientProtocolManagerFactory.adaptTransportConfiguration(TransportConfiguration tc) |
Modifier and Type | Field and Description |
---|---|
protected TransportConfiguration |
NodeAnnounceMessage.backupConnector |
protected TransportConfiguration |
NodeAnnounceMessage.connector |
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() |
TransportConfiguration |
BackupRegistrationMessage.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 backupGroupName,
String scaleDownGroupName,
boolean backup,
TransportConfiguration tc,
TransportConfiguration backupConnector) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
HornetQClientProtocolManagerFactory.adaptTransportConfiguration(TransportConfiguration tc)
Adapt the transport configuration by replacing the factoryClassName corresponding to an HornetQ's NettyConnectorFactory
by the Artemis-based implementation.
|
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
HornetQClientProtocolManagerFactory.adaptTransportConfiguration(TransportConfiguration tc)
Adapt the transport configuration by replacing the factoryClassName corresponding to an HornetQ's NettyConnectorFactory
by the Artemis-based implementation.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
TransportConfigurationUtil.isSameHost(TransportConfiguration tc1,
TransportConfiguration tc2) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
InVMConnection.getConnectorConfig() |
Modifier and Type | Method and Description |
---|---|
boolean |
InVMConnection.isSameTarget(TransportConfiguration... configs) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
NettyConnection.getConnectorConfig() |
Modifier and Type | Method and Description |
---|---|
boolean |
NettyConnection.isSameTarget(TransportConfiguration... configs) |
Modifier and Type | Method and Description |
---|---|
Acceptor |
RemotingService.createAcceptor(TransportConfiguration transportConfiguration) |
Modifier and Type | Method and Description |
---|---|
Acceptor |
RemotingServiceImpl.createAcceptor(TransportConfiguration info) |
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 |
---|---|
TransportConfiguration |
ActiveMQServerSideProtocolManagerFactory.adaptTransportConfiguration(TransportConfiguration tc) |
TransportConfiguration |
ClusterConnection.getConnector() |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
ActiveMQServerSideProtocolManagerFactory.adaptTransportConfiguration(TransportConfiguration tc) |
void |
ClusterController.addClusterConnection(SimpleString name,
TransportConfiguration[] tcConfigs,
ClusterConnectionConfiguration config)
add a locator for a cluster connection.
|
void |
BroadcastGroup.addConnector(TransportConfiguration tcConfig) |
ClusterControl |
ClusterController.connectToNode(TransportConfiguration transportConfiguration)
connect to a specific node in the cluster used for replication
|
ClusterControl |
ClusterController.connectToNodeInReplicatedCluster(TransportConfiguration transportConfiguration)
connect to a specific node in the cluster used for replication
|
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) |
void |
ClusterControl.sendNodeAnnounce(long currentEventID,
String nodeID,
String backupGroupName,
String scaleDownGroupName,
boolean isBackup,
TransportConfiguration config,
TransportConfiguration backupConfig)
announce this node to the cluster.
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterConnection.nodeAnnounced(long eventUID,
String nodeID,
String backupGroupName,
String scaleDownGroupName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
void |
ClusterConnection.nodeAnnounced(long eventUID,
String nodeID,
String backupGroupName,
String scaleDownGroupName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
boolean |
ColocatedHAManager.requestBackup(Pair<TransportConfiguration,TransportConfiguration> connectorPair,
int backupSize,
boolean replicated)
send a request to a live server to start a backup for us
|
boolean |
ColocatedHAManager.requestBackup(Pair<TransportConfiguration,TransportConfiguration> connectorPair,
int backupSize,
boolean replicated)
send a request to a live server to start a backup for us
|
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 backupGroupName,
String scaleDownGroupName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
void |
ClusterConnectionImpl.nodeAnnounced(long uniqueEventID,
String nodeID,
String backupGroupName,
String scaleDownGroupName,
Pair<TransportConfiguration,TransportConfiguration> connectorPair,
boolean backup) |
Constructor and Description |
---|
ClusterConnectionBridge(ClusterConnection clusterConnection,
ClusterManager clusterManager,
ServerLocatorInternal targetLocator,
ServerLocatorInternal discoveryLocator,
int initialConnectAttempts,
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,
ActiveMQServer server,
SimpleString managementAddress,
SimpleString managementNotificationAddress,
MessageFlowRecord flowRecord,
TransportConfiguration connector,
String storeAndForwardPrefix) |
ClusterConnectionImpl(ClusterManager manager,
DiscoveryGroupConfiguration dg,
TransportConfiguration connector,
SimpleString name,
SimpleString address,
int minLargeMessageSize,
long clientFailureCheckPeriod,
long connectionTTL,
long retryInterval,
double retryIntervalMultiplier,
long maxRetryInterval,
int initialConnectAttempts,
int reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
MessageLoadBalancingType messageLoadBalancingType,
int confirmationWindowSize,
int producerWindowSize,
ExecutorFactory executorFactory,
ActiveMQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
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 initialConnectAttempts,
int reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
MessageLoadBalancingType messageLoadBalancingType,
int confirmationWindowSize,
int producerWindowSize,
ExecutorFactory executorFactory,
ActiveMQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
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 initialConnectAttempts,
int reconnectAttempts,
long callTimeout,
long callFailoverTimeout,
boolean useDuplicateDetection,
MessageLoadBalancingType messageLoadBalancingType,
int confirmationWindowSize,
int producerWindowSize,
ExecutorFactory executorFactory,
ActiveMQServer server,
PostOffice postOffice,
ManagementService managementService,
ScheduledExecutorService scheduledExecutor,
int maxHops,
NodeManager nodeManager,
String clusterUser,
String clusterPassword,
boolean allowDirectConnectionsOnly,
long clusterNotificationInterval,
int clusterNotificationAttempts) |
Modifier and Type | Method and Description |
---|---|
TransportConfiguration |
QuorumManager.getLiveTransportConfiguration(String targetServerID) |
Modifier and Type | Method and Description |
---|---|
boolean |
QuorumManager.checkLive(TransportConfiguration liveTransportConfiguration) |
Modifier and Type | Method and Description |
---|---|
void |
SharedNothingLiveActivation.startReplication(CoreRemotingConnection rc,
ClusterConnection clusterConnection,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean isFailBackRequest) |
void |
SharedNothingLiveActivation.startReplication(CoreRemotingConnection rc,
ClusterConnection clusterConnection,
Pair<TransportConfiguration,TransportConfiguration> pair,
boolean isFailBackRequest) |
Constructor and Description |
---|
NamedNodeIdNodeLocator(String nodeID,
Pair<TransportConfiguration,TransportConfiguration> liveConfiguration) |
NamedNodeIdNodeLocator(String nodeID,
Pair<TransportConfiguration,TransportConfiguration> liveConfiguration) |
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[] |
ActiveMQConnectionFactory.getStaticConnectors() |
Constructor and Description |
---|
ActiveMQConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
ActiveMQJMSConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
ActiveMQQueueConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
ActiveMQTopicConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
ActiveMQXAConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
ActiveMQXAQueueConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
ActiveMQXATopicConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
Modifier and Type | Method and Description |
---|---|
static TransportConfiguration |
TransportConfigurationEncodingSupport.decode(ActiveMQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
static List<Pair<TransportConfiguration,TransportConfiguration>> |
TransportConfigurationEncodingSupport.decodeConfigs(ActiveMQBuffer buffer) |
static List<Pair<TransportConfiguration,TransportConfiguration>> |
TransportConfigurationEncodingSupport.decodeConfigs(ActiveMQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
static void |
TransportConfigurationEncodingSupport.encode(ActiveMQBuffer buffer,
TransportConfiguration config) |
static int |
TransportConfigurationEncodingSupport.getEncodeSize(TransportConfiguration config) |
Modifier and Type | Method and Description |
---|---|
static void |
TransportConfigurationEncodingSupport.encodeConfigs(ActiveMQBuffer buffer,
List<Pair<TransportConfiguration,TransportConfiguration>> configs) |
static void |
TransportConfigurationEncodingSupport.encodeConfigs(ActiveMQBuffer 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() |
Constructor and Description |
---|
XARecoveryConfig(boolean ha,
TransportConfiguration[] transportConfiguration,
String username,
String password,
Map<String,String> properties) |
XARecoveryConfig(boolean ha,
TransportConfiguration[] transportConfiguration,
String username,
String password,
Map<String,String> properties,
ClientProtocolManagerFactory clientProtocolManager) |
Modifier and Type | Method and Description |
---|---|
default boolean |
RemotingConnection.isSameTarget(TransportConfiguration... configs) |
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.
|
boolean |
Connection.isSameTarget(TransportConfiguration... configs) |
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 © 2019 JBoss by Red Hat. All rights reserved.