Modifier and Type | Method and Description |
---|---|
ServerLocator |
ServerLocator.addClusterTopologyListener(ClusterTopologyListener listener) |
ServerLocator |
ServerLocator.addIncomingInterceptor(Interceptor interceptor)
Adds an interceptor which will be executed after packets are received from the server.
|
ServerLocator |
ServerLocator.addOutgoingInterceptor(Interceptor interceptor)
Adds an interceptor which will be executed before packets are sent to the server.
|
static ServerLocator |
ActiveMQClient.createServerLocator(boolean ha,
DiscoveryGroupConfiguration groupConfiguration)
Create a ServerLocator which creates session factories from a set of live servers, no HA
backup information is propagated to the client The UDP address and port are used to listen for
live servers in the cluster
|
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.createServerLocator(String url)
Creates an ActiveMQConnectionFactory;
|
static ServerLocator |
ActiveMQClient.createServerLocatorWithHA(DiscoveryGroupConfiguration groupConfiguration)
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.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(DiscoveryGroupConfiguration groupConfiguration)
Create a ServerLocator which creates session factories from a set of live servers, no HA
backup information is propagated to the client
|
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
|
ServerLocator |
ClientSessionFactory.getServerLocator() |
ServerLocator |
ServerLocator.setAckBatchSize(int ackBatchSize)
Sets the acknowledgments batch size.
|
ServerLocator |
ServerLocator.setAutoGroup(boolean autoGroup)
Sets whether producers created through this factory will automatically
assign a group ID to the messages they sent.
|
ServerLocator |
ServerLocator.setBlockOnAcknowledge(boolean blockOnAcknowledge)
Sets whether consumers created through this factory will block while
sending message acknowledgments or do it asynchronously.
|
ServerLocator |
ServerLocator.setBlockOnDurableSend(boolean blockOnDurableSend)
Sets whether producers created through this factory will block while sending durable messages or do it asynchronously.
|
ServerLocator |
ServerLocator.setBlockOnNonDurableSend(boolean blockOnNonDurableSend)
Sets whether producers created through this factory will block while sending non-durable messages or do it asynchronously.
|
ServerLocator |
ServerLocator.setCacheLargeMessagesClient(boolean cached)
Sets whether large messages received by consumers created through this factory will be cached in temporary files or not.
|
ServerLocator |
ServerLocator.setCallFailoverTimeout(long callFailoverTimeout)
Sets the blocking call failover timeout.
|
ServerLocator |
ServerLocator.setCallTimeout(long callTimeout)
Sets the blocking call timeout.
|
ServerLocator |
ServerLocator.setClientFailureCheckPeriod(long clientFailureCheckPeriod)
Sets the period (in milliseconds) used to check if a client has failed to receive pings from
the server.
|
ServerLocator |
ServerLocator.setCompressLargeMessage(boolean compressLargeMessages)
Sets whether to compress or not large messages.
|
ServerLocator |
ServerLocator.setConfirmationWindowSize(int confirmationWindowSize)
Sets the size for the confirmation window buffer of clients using this factory.
|
ServerLocator |
ServerLocator.setConnectionLoadBalancingPolicyClassName(String loadBalancingPolicyClassName)
Sets the class name of the connection load balancing policy.
|
ServerLocator |
ServerLocator.setConnectionTTL(long connectionTTL)
Sets this factory's connections time-to-live.
|
ServerLocator |
ServerLocator.setConsumerMaxRate(int consumerMaxRate)
Sets the maximum rate of message consumption for consumers created through this factory.
|
ServerLocator |
ServerLocator.setConsumerWindowSize(int consumerWindowSize)
Sets the window size for flow control of the consumers created through this factory.
|
ServerLocator |
ServerLocator.setFailoverOnInitialConnection(boolean failover)
Deprecated.
|
ServerLocator |
ServerLocator.setGroupID(String groupID)
Sets the group ID that will be set on each message sent through this factory.
|
ServerLocator |
ServerLocator.setIncomingInterceptorList(String interceptorList) |
ServerLocator |
ServerLocator.setInitialConnectAttempts(int reconnectAttempts)
Sets the maximum number of attempts to establish an initial connection.
|
ServerLocator |
ServerLocator.setInitialMessagePacketSize(int size)
Sets the initial size of messages created through this factory.
|
ServerLocator |
ServerLocator.setMaxRetryInterval(long maxRetryInterval)
Sets the maximum retry interval.
|
ServerLocator |
ServerLocator.setMinLargeMessageSize(int minLargeMessageSize)
Sets the large message size threshold.
|
ServerLocator |
ServerLocator.setOutgoingInterceptorList(String interceptorList) |
ServerLocator |
ServerLocator.setPreAcknowledge(boolean preAcknowledge)
Sets to
true to pre-acknowledge consumed messages on the
server before they are sent to consumers, else set to false
to let clients acknowledge the message they consume. |
ServerLocator |
ServerLocator.setProducerMaxRate(int producerMaxRate)
Sets the maximum rate of message production for producers created through this factory.
|
ServerLocator |
ServerLocator.setProducerWindowSize(int producerWindowSize)
Returns the window size for flow control of the producers created through this factory.
|
ServerLocator |
ServerLocator.setProtocolManagerFactory(ClientProtocolManagerFactory protocolManager) |
ServerLocator |
ServerLocator.setReconnectAttempts(int reconnectAttempts)
Sets the maximum number of attempts to retry connection in case of failure.
|
ServerLocator |
ServerLocator.setRetryInterval(long retryInterval)
Sets the time to retry connections created by this factory after failure.
|
ServerLocator |
ServerLocator.setRetryIntervalMultiplier(double retryIntervalMultiplier)
Sets the multiplier to apply to successive retry intervals.
|
ServerLocator |
ServerLocator.setScheduledThreadPoolMaxSize(int scheduledThreadPoolMaxSize)
Sets the maximum size of the scheduled thread pool.
|
ServerLocator |
ServerLocator.setThreadPoolMaxSize(int threadPoolMaxSize)
Sets the maximum size of the thread pool.
|
ServerLocator |
ServerLocator.setUseGlobalPools(boolean useGlobalPools)
Sets whether this factory will use global thread pools (shared among all the factories in the same JVM)
or its own pools.
|
ServerLocator |
ServerLocator.setUseTopologyForLoadBalancing(boolean useTopologyForLoadBalancing) |
Constructor and Description |
---|
ActiveMQManagementProxy(ServerLocator locator,
String username,
String password) |
Modifier and Type | Interface and Description |
---|---|
interface |
ServerLocatorInternal |
Modifier and Type | Class and Description |
---|---|
class |
ServerLocatorImpl
This is the implementation of
ServerLocator and all
the proper javadoc is located on that interface. |
Modifier and Type | Method and Description |
---|---|
ServerLocator |
ClientSessionFactoryImpl.getServerLocator() |
static ServerLocator |
ServerLocatorImpl.newLocator(String uri) |
static ServerLocator |
ServerLocatorImpl.newLocator(URI uri) |
ServerLocator |
ServerLocatorImpl.setIncomingInterceptorList(String interceptorList) |
ServerLocator |
ServerLocatorImpl.setOutgoingInterceptorList(String interceptorList) |
ServerLocator |
ServerLocatorImpl.setProtocolManagerFactory(ClientProtocolManagerFactory protocolManagerFactory) |
ServerLocator |
ServerLocatorImpl.setUseTopologyForLoadBalancing(boolean useTopologyForLoadBalancing) |
Modifier and Type | Method and Description |
---|---|
ServerLocator |
ActiveMQClientProtocolManagerFactory.getLocator() |
Modifier and Type | Method and Description |
---|---|
static ActiveMQClientProtocolManagerFactory |
ActiveMQClientProtocolManagerFactory.getInstance(ServerLocator locator) |
void |
ActiveMQClientProtocolManagerFactory.setLocator(ServerLocator locator) |
Modifier and Type | Method and Description |
---|---|
ServerLocator |
HornetQClientProtocolManagerFactory.getLocator() |
Modifier and Type | Method and Description |
---|---|
void |
HornetQClientProtocolManagerFactory.setLocator(ServerLocator locator) |
Modifier and Type | Method and Description |
---|---|
ServerLocator |
BackupManager.BackupConnector.getBackupServerLocator()
This is for test assertions, please be careful, don't use outside of testing!
|
ServerLocator |
ActiveMQServerSideProtocolManagerFactory.getLocator() |
ServerLocator |
ClusterController.getReplicationLocator() |
ServerLocator |
ClusterController.getServerLocator(SimpleString name) |
Modifier and Type | Method and Description |
---|---|
static ActiveMQServerSideProtocolManagerFactory |
ActiveMQServerSideProtocolManagerFactory.getInstance(ServerLocator locator,
StorageManager storageManager) |
void |
ActiveMQServerSideProtocolManagerFactory.setLocator(ServerLocator locator) |
Modifier and Type | Method and Description |
---|---|
ServerLocator |
ActiveMQConnectionFactory.getServerLocator() |
Constructor and Description |
---|
ActiveMQConnectionFactory(ServerLocator serverLocator) |
ActiveMQJMSConnectionFactory(ServerLocator serverLocator) |
ActiveMQQueueConnectionFactory(ServerLocator serverLocator) |
ActiveMQTopicConnectionFactory(ServerLocator serverLocator) |
ActiveMQXAConnectionFactory(ServerLocator serverLocator) |
ActiveMQXAQueueConnectionFactory(ServerLocator serverLocator) |
ActiveMQXATopicConnectionFactory(ServerLocator serverLocator) |
Modifier and Type | Method and Description |
---|---|
ServerLocator |
XARecoveryConfig.createServerLocator()
Create a serverLocator using the configuration
|
Modifier and Type | Method and Description |
---|---|
ServerLocator |
ClientProtocolManagerFactory.getLocator() |
Modifier and Type | Method and Description |
---|---|
void |
ClientProtocolManagerFactory.setLocator(ServerLocator locator) |
Modifier and Type | Method and Description |
---|---|
protected ServerLocator |
InVMServerLocatorSchema.internalNewObject(URI uri,
Map<String,String> query,
String name) |
protected ServerLocator |
JGroupsServerLocatorSchema.internalNewObject(URI uri,
Map<String,String> query,
String name) |
protected ServerLocator |
TCPServerLocatorSchema.internalNewObject(URI uri,
Map<String,String> query,
String name) |
protected ServerLocator |
UDPServerLocatorSchema.internalNewObject(URI uri,
Map<String,String> query,
String name) |
Modifier and Type | Method and Description |
---|---|
protected URI |
InVMServerLocatorSchema.internalNewURI(ServerLocator bean) |
protected URI |
JGroupsServerLocatorSchema.internalNewURI(ServerLocator bean) |
protected URI |
TCPServerLocatorSchema.internalNewURI(ServerLocator bean) |
protected URI |
UDPServerLocatorSchema.internalNewURI(ServerLocator bean) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.