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[] |
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 |
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.