public class HornetQClient extends Object
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
.Modifier and Type | Method and Description |
---|---|
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
|
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
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 updatespublic static ServerLocator createServerLocator(boolean ha, DiscoveryGroupConfiguration groupConfiguration)
discoveryAddress
- The UDP group address to listen for updatesdiscoveryPort
- the UDP port to listen for updatespublic 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 updatesCopyright © 2012 JBoss by Red Hat. All Rights Reserved.