|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.hornetq.api.core.client.HornetQClient
public class HornetQClient
Utility class for creating HornetQ ClientSessionFactory
objects.
Once a ClientSessionFactory
has been created, it can be further configured
using its setter methods before creating the sessions. Once a session is created,
the factory can no longer be modified (its setter methods will throw a IllegalStateException
.
Method Summary | |
---|---|
static ServerLocator |
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 |
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 |
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 |
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 |
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 The UDP address and port are used to listen for live servers in the cluster |
static ServerLocator |
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 |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String DEFAULT_CONNECTION_LOAD_BALANCING_POLICY_CLASS_NAME
public static final long DEFAULT_CLIENT_FAILURE_CHECK_PERIOD
public static final long DEFAULT_CONNECTION_TTL
public static final int DEFAULT_MIN_LARGE_MESSAGE_SIZE
public static final boolean DEFAULT_COMPRESS_LARGE_MESSAGES
public static final int DEFAULT_CONSUMER_WINDOW_SIZE
public static final int DEFAULT_CONSUMER_MAX_RATE
public static final int DEFAULT_CONFIRMATION_WINDOW_SIZE
public static final int DEFAULT_PRODUCER_WINDOW_SIZE
public static final int DEFAULT_PRODUCER_MAX_RATE
public static final boolean DEFAULT_BLOCK_ON_ACKNOWLEDGE
public static final boolean DEFAULT_BLOCK_ON_DURABLE_SEND
public static final boolean DEFAULT_BLOCK_ON_NON_DURABLE_SEND
public static final boolean DEFAULT_AUTO_GROUP
public static final long DEFAULT_CALL_TIMEOUT
public static final int DEFAULT_ACK_BATCH_SIZE
public static final boolean DEFAULT_PRE_ACKNOWLEDGE
public static final long DEFAULT_DISCOVERY_INITIAL_WAIT_TIMEOUT
public static final long DEFAULT_DISCOVERY_REFRESH_TIMEOUT
public static final int DEFAULT_DISCOVERY_PORT
public static final long DEFAULT_RETRY_INTERVAL
public static final double DEFAULT_RETRY_INTERVAL_MULTIPLIER
public static final long DEFAULT_MAX_RETRY_INTERVAL
public static final int DEFAULT_RECONNECT_ATTEMPTS
public static final int INITIAL_CONNECT_ATTEMPTS
public static final boolean DEFAULT_FAILOVER_ON_INITIAL_CONNECTION
public static final boolean DEFAULT_IS_HA
public static final boolean DEFAULT_USE_GLOBAL_POOLS
public static final int DEFAULT_THREAD_POOL_MAX_SIZE
public static final int DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE
public static final boolean DEFAULT_CACHE_LARGE_MESSAGE_CLIENT
public static final int DEFAULT_INITIAL_MESSAGE_PACKET_SIZE
public static final boolean DEFAULT_XA
public static final boolean DEFAULT_HA
Method Detail |
---|
public static ServerLocator createServerLocatorWithoutHA(TransportConfiguration... transportConfigurations)
transportConfigurations
-
public static ServerLocator createServerLocator(boolean ha, TransportConfiguration... transportConfigurations)
transportConfigurations
-
public static ServerLocator createServerLocatorWithoutHA(DiscoveryGroupConfiguration groupConfiguration)
discoveryAddress
- The UDP group address to listen for updatesdiscoveryPort
- the UDP port to listen for updates
public static ServerLocator createServerLocator(boolean ha, DiscoveryGroupConfiguration groupConfiguration)
discoveryAddress
- The UDP group address to listen for updatesdiscoveryPort
- the UDP port to listen for updates
public static ServerLocator createServerLocatorWithHA(TransportConfiguration... initialServers)
initialServers
- The initial set of servers used to make a connection to the cluster. Each one is tried in turn until a successful connection is made. Once
a connection is made, the cluster topology is downloaded and the rest of the list is ignored.
public static ServerLocator createServerLocatorWithHA(DiscoveryGroupConfiguration groupConfiguration)
discoveryAddress
- The UDP group address to listen for updatesdiscoveryPort
- the UDP port to listen for updates
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |