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 active servers, no HA
backup information is propagated to the client The UDP address and port are used to listen for
active 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 active 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.setCompressionLevel(int compressionLevel) |
Sets what compressionLevel to use when compressing messages
Value must be -1 (default), or 0-9
|
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.setFailoverAttempts(int attempts) |
Sets the maximum number of failover attempts to establish a connection to other primary servers after a connection failure.
|
ServerLocator |
ServerLocator.setFailoverOnInitialConnection(boolean failover) |
Deprecated.
|
ServerLocator |
ServerLocator.setFlowControlThreadPoolMaxSize(int flowControlThreadPoolMaxSize) |
Sets the maximum size of the flow-control thread pool.
|
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.setPasswordCodec(String passwordCodec) |
|
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) |
|