Uses of Interface
org.apache.activemq.artemis.api.core.client.ServerLocator
Packages that use ServerLocator
Package
Description
-
Uses of ServerLocator in org.apache.activemq.artemis.api.core.client
Methods in org.apache.activemq.artemis.api.core.client that return ServerLocatorModifier and TypeMethodDescriptionServerLocator.addClusterTopologyListener(ClusterTopologyListener listener) ServerLocator.addIncomingInterceptor(Interceptor interceptor) Adds an interceptor which will be executed after packets are received from the server.ServerLocator.addOutgoingInterceptor(Interceptor interceptor) Adds an interceptor which will be executed before packets are sent to the server.static ServerLocatorActiveMQClient.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 clusterstatic ServerLocatorActiveMQClient.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 clientstatic ServerLocatorActiveMQClient.createServerLocator(String url) Creates an ActiveMQConnectionFactory;static ServerLocatorActiveMQClient.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 ServerLocatorActiveMQClient.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 ServerLocatorActiveMQClient.createServerLocatorWithoutHA(DiscoveryGroupConfiguration groupConfiguration) Create a ServerLocator which creates session factories from a set of active servers, no HA backup information is propagated to the clientstatic ServerLocatorActiveMQClient.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 clientClientSessionFactory.getServerLocator()Returns the server locator associated with this session factory.ServerLocator.setAckBatchSize(int ackBatchSize) Sets the acknowledgments batch size.ServerLocator.setAutoGroup(boolean autoGroup) Sets whether producers created through this factory will automatically assign a group ID to the messages they sent.ServerLocator.setBlockOnAcknowledge(boolean blockOnAcknowledge) Sets whether consumers created through this factory will block while sending message acknowledgments or do it asynchronously.ServerLocator.setBlockOnDurableSend(boolean blockOnDurableSend) Sets whether producers created through this factory will block while sending durable messages or do it asynchronously.ServerLocator.setBlockOnNonDurableSend(boolean blockOnNonDurableSend) Sets whether producers created through this factory will block while sending non-durable messages or do it asynchronously.ServerLocator.setCacheLargeMessagesClient(boolean cached) Sets whether large messages received by consumers created through this factory will be cached in temporary files or not.ServerLocator.setCallFailoverTimeout(long callFailoverTimeout) Sets the blocking call failover timeout.ServerLocator.setCallTimeout(long callTimeout) Sets the blocking call timeout.ServerLocator.setClientFailureCheckPeriod(long clientFailureCheckPeriod) Sets the period (in milliseconds) used to check if a client has failed to receive pings from the server.ServerLocator.setCompressionLevel(int compressionLevel) Sets what compressionLevel to use when compressing messages Value must be -1 (default), or 0-9ServerLocator.setCompressLargeMessage(boolean compressLargeMessages) Sets whether to compress or not large messages.ServerLocator.setConfirmationWindowSize(int confirmationWindowSize) Sets the size for the confirmation window buffer of clients using this factory.ServerLocator.setConnectionLoadBalancingPolicyClassName(String loadBalancingPolicyClassName) Sets the class name of the connection load balancing policy.ServerLocator.setConnectionTTL(long connectionTTL) Sets this factory's connections time-to-live.ServerLocator.setConsumerMaxRate(int consumerMaxRate) Sets the maximum rate of message consumption for consumers created through this factory.ServerLocator.setConsumerWindowSize(int consumerWindowSize) Sets the window size for flow control of the consumers created through this factory.ServerLocator.setFailoverAttempts(int attempts) Sets the maximum number of failover attempts to establish a connection to other primary servers after a connection failure.ServerLocator.setFailoverOnInitialConnection(boolean failover) Deprecated.ServerLocator.setFlowControlThreadPoolMaxSize(int flowControlThreadPoolMaxSize) Sets the maximum size of the flow-control thread pool.ServerLocator.setGroupID(String groupID) Sets the group ID that will be set on each message sent through this factory.ServerLocator.setIncomingInterceptorList(String interceptorList) Set the list ofInterceptors to use for incoming packets.ServerLocator.setInitialConnectAttempts(int reconnectAttempts) Sets the maximum number of attempts to establish an initial connection.ServerLocator.setInitialMessagePacketSize(int size) Sets the initial size of messages created through this factory.ServerLocator.setMaxRetryInterval(long maxRetryInterval) Sets the maximum retry interval.ServerLocator.setMinLargeMessageSize(int minLargeMessageSize) Sets the large message size threshold.ServerLocator.setOnMessageCloseTimeout(int onMessageCloseTimeout) Sets the timeout in milliseconds for onMessage completion when closing ClientConsumers created through this factory.ServerLocator.setOutgoingInterceptorList(String interceptorList) Set the list ofInterceptors to use for outgoing packets.ServerLocator.setPasswordCodec(String passwordCodec) ServerLocator.setPreAcknowledge(boolean preAcknowledge) Sets totrueto pre-acknowledge consumed messages on the server before they are sent to consumers, else set tofalseto let clients acknowledge the message they consume.ServerLocator.setProducerMaxRate(int producerMaxRate) Sets the maximum rate of message production for producers created through this factory.ServerLocator.setProducerWindowSize(int producerWindowSize) Returns the window size for flow control of the producers created through this factory.ServerLocator.setProtocolManagerFactory(ClientProtocolManagerFactory protocolManager) ServerLocator.setReconnectAttempts(int reconnectAttempts) Sets the maximum number of attempts to retry connection in case of failure.ServerLocator.setRetryInterval(long retryInterval) Sets the time to retry connections created by this factory after failure.ServerLocator.setRetryIntervalMultiplier(double retryIntervalMultiplier) Sets the multiplier to apply to successive retry intervals.ServerLocator.setScheduledThreadPoolMaxSize(int scheduledThreadPoolMaxSize) Sets the maximum size of the scheduled thread pool.ServerLocator.setThreadPoolMaxSize(int threadPoolMaxSize) Sets the maximum size of the thread pool.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.setUseTopologyForLoadBalancing(boolean useTopologyForLoadBalancing) -
Uses of ServerLocator in org.apache.activemq.artemis.api.core.management
Methods in org.apache.activemq.artemis.api.core.management with parameters of type ServerLocatorModifier and TypeMethodDescriptionstatic voidManagementHelper.doManagement(ServerLocator locator, String user, String password, ManagementHelper.MessageAcceptor setup, ManagementHelper.MessageAcceptor ok, ManagementHelper.MessageAcceptor failed) Constructors in org.apache.activemq.artemis.api.core.management with parameters of type ServerLocatorModifierConstructorDescriptionActiveMQManagementProxy(ServerLocator locator, String username, String password) -
Uses of ServerLocator in org.apache.activemq.artemis.spi.core.remoting
Methods in org.apache.activemq.artemis.spi.core.remoting that return ServerLocatorMethods in org.apache.activemq.artemis.spi.core.remoting with parameters of type ServerLocator