org.hornetq.api.jms.management
public interface ConnectionFactoryControl
ServerLocator
,
ClientSessionFactory
Modifier and Type | Method and Description |
---|---|
void |
addJNDI(String jndi)
Add the JNDI binding to this destination
|
long |
getCallFailoverTimeout() |
long |
getCallTimeout() |
long |
getClientFailureCheckPeriod() |
String |
getClientID()
Returns the Client ID of this connection factory (or
null if it is not set. |
int |
getConfirmationWindowSize() |
String |
getConnectionLoadBalancingPolicyClassName() |
long |
getConnectionTTL() |
int |
getConsumerMaxRate() |
int |
getConsumerWindowSize() |
DiscoveryGroupConfiguration |
getDiscoveryGroupConfiguration()
get the discovery group configuration
|
int |
getDupsOKBatchSize()
Returns the batch size (in bytes) between acknowledgements when using DUPS_OK_ACKNOWLEDGE
mode.
|
int |
getFactoryType()
return the type of factory
|
String |
getGroupID() |
int |
getInitialMessagePacketSize() |
String[] |
getJNDIBindings()
Returns the JNDI bindings associated to this connection factory.
|
long |
getMaxRetryInterval() |
int |
getMinLargeMessageSize() |
String |
getName()
Returns the configuration name of this connection factory.
|
int |
getProducerMaxRate() |
int |
getProducerWindowSize() |
int |
getReconnectAttempts() |
long |
getRetryInterval() |
double |
getRetryIntervalMultiplier() |
int |
getScheduledThreadPoolMaxSize() |
TransportConfiguration[] |
getStaticConnectors() |
int |
getThreadPoolMaxSize() |
int |
getTransactionBatchSize()
Returns the batch size (in bytes) between acknowledgements when using a transacted session.
|
boolean |
isAutoGroup() |
boolean |
isBlockOnAcknowledge() |
boolean |
isBlockOnDurableSend() |
boolean |
isBlockOnNonDurableSend() |
boolean |
isCacheLargeMessagesClient() |
boolean |
isCompressLargeMessages() |
boolean |
isFailoverOnInitialConnection() |
boolean |
isHA()
does ths cf support HA
|
boolean |
isPreAcknowledge() |
boolean |
isUseGlobalPools() |
void |
removeJNDI(String jndi)
Remove a JNDI binding
|
void |
setAutoGroup(boolean autoGroup) |
void |
setBlockOnAcknowledge(boolean blockOnAcknowledge) |
void |
setBlockOnDurableSend(boolean blockOnDurableSend) |
void |
setBlockOnNonDurableSend(boolean blockOnNonDurableSend) |
void |
setCacheLargeMessagesClient(boolean cacheLargeMessagesClient) |
void |
setCallFailoverTimeout(long callTimeout) |
void |
setCallTimeout(long callTimeout) |
void |
setClientFailureCheckPeriod(long clientFailureCheckPeriod) |
void |
setClientID(String clientID)
Sets the Client ID for this connection factory.
|
void |
setCompressLargeMessages(boolean compress) |
void |
setConfirmationWindowSize(int confirmationWindowSize) |
void |
setConnectionLoadBalancingPolicyClassName(String connectionLoadBalancingPolicyClassName) |
void |
setConnectionTTL(long connectionTTL) |
void |
setConsumerMaxRate(int consumerMaxRate) |
void |
setConsumerWindowSize(int consumerWindowSize) |
void |
setDupsOKBatchSize(int dupsOKBatchSize) |
void |
setFailoverOnInitialConnection(boolean failoverOnInitialConnection) |
void |
setGroupID(String groupID) |
void |
setMaxRetryInterval(long retryInterval) |
void |
setMinLargeMessageSize(int minLargeMessageSize) |
void |
setPreAcknowledge(boolean preAcknowledge) |
void |
setProducerMaxRate(int producerMaxRate) |
void |
setProducerWindowSize(int producerWindowSize) |
void |
setReconnectAttempts(int reconnectAttempts) |
void |
setRetryInterval(long retryInterval) |
void |
setRetryIntervalMultiplier(double retryIntervalMultiplier) |
void |
setScheduledThreadPoolMaxSize(int scheduledThreadPoolMaxSize) |
void |
setThreadPoolMaxSize(int threadPoolMaxSize) |
void |
setTransactionBatchSize(int transactionBatchSize) |
void |
setUseGlobalPools(boolean useGlobalPools) |
String getName()
String[] getJNDIBindings()
boolean isHA()
int getFactoryType()
String getClientID()
null
if it is not set.void setClientID(String clientID)
boolean isCompressLargeMessages()
ServerLocator#isCompressLargeMessage()
void setCompressLargeMessages(boolean compress)
long getClientFailureCheckPeriod()
ServerLocator#getClientFailureCheckPeriod()
void setClientFailureCheckPeriod(long clientFailureCheckPeriod)
ServerLocator#setClientFailureCheckPeriod
long getCallTimeout()
ServerLocator#getCallTimeout()
void setCallTimeout(long callTimeout)
ServerLocator#setCallTimeout(long)
long getCallFailoverTimeout()
ServerLocator#getCallFailoverTimeout()
void setCallFailoverTimeout(long callTimeout)
ServerLocator#setCallFailoverTimeout(long)
int getDupsOKBatchSize()
ServerLocator#getAckBatchSize()
,
Session.DUPS_OK_ACKNOWLEDGE
void setDupsOKBatchSize(int dupsOKBatchSize)
ServerLocator#setAckBatchSize(int)
int getConsumerMaxRate()
ServerLocator#getConsumerMaxRate()
void setConsumerMaxRate(int consumerMaxRate)
ServerLocator#setConsumerMaxRate(int)
int getConsumerWindowSize()
ServerLocator#getConsumerWindowSize()
void setConsumerWindowSize(int consumerWindowSize)
ServerLocator#setConfirmationWindowSize(int)
int getProducerMaxRate()
ServerLocator#getProducerMaxRate()
void setProducerMaxRate(int producerMaxRate)
ServerLocator#setProducerMaxRate(int)
int getConfirmationWindowSize()
ServerLocator#getConfirmationWindowSize()
void setConfirmationWindowSize(int confirmationWindowSize)
ServerLocator#setConfirmationWindowSize(int)
boolean isBlockOnAcknowledge()
ServerLocator#isBlockOnAcknowledge()
void setBlockOnAcknowledge(boolean blockOnAcknowledge)
ServerLocator#setBlockOnAcknowledge(boolean)
boolean isBlockOnDurableSend()
ServerLocator#isBlockOnDurableSend()
void setBlockOnDurableSend(boolean blockOnDurableSend)
ServerLocator#setBlockOnDurableSend(boolean)
boolean isBlockOnNonDurableSend()
ServerLocator#isBlockOnNonDurableSend()
void setBlockOnNonDurableSend(boolean blockOnNonDurableSend)
ServerLocator#setBlockOnNonDurableSend(boolean)
boolean isPreAcknowledge()
ServerLocator#isPreAcknowledge()
void setPreAcknowledge(boolean preAcknowledge)
ServerLocator#setPreAcknowledge(boolean)
long getConnectionTTL()
ServerLocator#getConnectionTTL()
void setConnectionTTL(long connectionTTL)
ServerLocator#setConnectionTTL(long)
int getTransactionBatchSize()
ServerLocator#getAckBatchSize()
void setTransactionBatchSize(int transactionBatchSize)
ServerLocator#setAckBatchSize(int)
int getMinLargeMessageSize()
ServerLocator#getMinLargeMessageSize()
void setMinLargeMessageSize(int minLargeMessageSize)
ServerLocator#setMinLargeMessageSize(int)
boolean isAutoGroup()
ServerLocator#isAutoGroup()
void setAutoGroup(boolean autoGroup)
ServerLocator#setAutoGroup(boolean)
long getRetryInterval()
ServerLocator#getRetryInterval()
void setRetryInterval(long retryInterval)
ServerLocator#setRetryInterval(long)
double getRetryIntervalMultiplier()
ServerLocator#getRetryIntervalMultiplier()
void setRetryIntervalMultiplier(double retryIntervalMultiplier)
ServerLocator#setRetryIntervalMultiplier(double)
int getReconnectAttempts()
ServerLocator#getReconnectAttempts()
void setReconnectAttempts(int reconnectAttempts)
ServerLocator#setReconnectAttempts(int)
boolean isFailoverOnInitialConnection()
ServerLocator#isFailoverOnInitialConnection()
void setFailoverOnInitialConnection(boolean failoverOnInitialConnection)
ServerLocator#setFailoverOnInitialConnection(boolean)
int getProducerWindowSize()
void setProducerWindowSize(int producerWindowSize)
ServerLocator#setProducerWindowSize(int)
boolean isCacheLargeMessagesClient()
ServerLocator#isCacheLargeMessagesClient()
void setCacheLargeMessagesClient(boolean cacheLargeMessagesClient)
ServerLocator#setCacheLargeMessagesClient(boolean)
long getMaxRetryInterval()
ServerLocator#getMaxRetryInterval()
void setMaxRetryInterval(long retryInterval)
ServerLocator#setMaxRetryInterval(long)
int getScheduledThreadPoolMaxSize()
ServerLocator#getScheduledThreadPoolMaxSize()
void setScheduledThreadPoolMaxSize(int scheduledThreadPoolMaxSize)
ServerLocator#setScheduledThreadPoolMaxSize(int)
int getThreadPoolMaxSize()
ServerLocator#getThreadPoolMaxSize()
void setThreadPoolMaxSize(int threadPoolMaxSize)
ServerLocator#setThreadPoolMaxSize(int)
String getGroupID()
ServerLocator#getGroupID()
void setGroupID(String groupID)
ServerLocator#setGroupID(String)
int getInitialMessagePacketSize()
ServerLocator#getInitialMessagePacketSize()
boolean isUseGlobalPools()
ServerLocator#isUseGlobalPools()
void setUseGlobalPools(boolean useGlobalPools)
ServerLocator#setUseGlobalPools(boolean)
String getConnectionLoadBalancingPolicyClassName()
ServerLocator#getConnectionLoadBalancingPolicyClassName()
void setConnectionLoadBalancingPolicyClassName(String connectionLoadBalancingPolicyClassName)
ServerLocator#setConnectionLoadBalancingPolicyClassName(String)
TransportConfiguration[] getStaticConnectors()
ClientSessionFactory#getStaticConnectors()
DiscoveryGroupConfiguration getDiscoveryGroupConfiguration()
void addJNDI(String jndi) throws Exception
Exception
Copyright © 2016 JBoss, a division of Red Hat. All Rights Reserved.