public class JMSConnectionFactoryControlImpl extends StandardMBean implements ConnectionFactoryControl
| Constructor and Description |
|---|
JMSConnectionFactoryControlImpl(ConnectionFactoryConfiguration cfConfig,
ActiveMQConnectionFactory cf,
JMSServerManager jmsManager,
String name) |
| Modifier and Type | Method and Description |
|---|---|
void |
addBinding(String binding)
Add the Registry 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() |
long |
getMaxRetryInterval() |
MBeanInfo |
getMBeanInfo() |
int |
getMinLargeMessageSize() |
String |
getName()
Returns the configuration name of this connection factory.
|
int |
getProducerMaxRate() |
int |
getProducerWindowSize() |
String |
getProtocolManagerFactoryStr()
get the protocol manager factory name
|
int |
getReconnectAttempts() |
String[] |
getRegistryBindings()
Returns the Registry bindings associated to this connection factory.
|
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 |
removeBinding(String binding)
Remove a Registry 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 name) |
void |
setConnectionTTL(long connectionTTL) |
void |
setConsumerMaxRate(int consumerMaxRate) |
void |
setConsumerWindowSize(int consumerWindowSize) |
void |
setDupsOKBatchSize(int dupsOKBatchSize) |
void |
setFailoverOnInitialConnection(boolean failover) |
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 |
setProtocolManagerFactoryStr(String protocolManagerFactoryStr)
set the protocol manager factory name
|
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) |
cacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementationpublic JMSConnectionFactoryControlImpl(ConnectionFactoryConfiguration cfConfig, ActiveMQConnectionFactory cf, JMSServerManager jmsManager, String name) throws NotCompliantMBeanException
NotCompliantMBeanExceptionpublic String[] getRegistryBindings()
ConnectionFactoryControlgetRegistryBindings in interface ConnectionFactoryControlpublic boolean isCompressLargeMessages()
isCompressLargeMessages in interface ConnectionFactoryControlServerLocator.isCompressLargeMessage()public void setCompressLargeMessages(boolean compress)
setCompressLargeMessages in interface ConnectionFactoryControlpublic boolean isHA()
ConnectionFactoryControlisHA in interface ConnectionFactoryControlpublic int getFactoryType()
ConnectionFactoryControlgetFactoryType in interface ConnectionFactoryControlpublic String getClientID()
ConnectionFactoryControlnull if it is not set.getClientID in interface ConnectionFactoryControlpublic long getClientFailureCheckPeriod()
getClientFailureCheckPeriod in interface ConnectionFactoryControlServerLocator.getClientFailureCheckPeriod()public void setClientID(String clientID)
ConnectionFactoryControlsetClientID in interface ConnectionFactoryControlpublic void setDupsOKBatchSize(int dupsOKBatchSize)
setDupsOKBatchSize in interface ConnectionFactoryControlServerLocator.setAckBatchSize(int)public void setTransactionBatchSize(int transactionBatchSize)
setTransactionBatchSize in interface ConnectionFactoryControlServerLocator.setAckBatchSize(int)public void setClientFailureCheckPeriod(long clientFailureCheckPeriod)
setClientFailureCheckPeriod in interface ConnectionFactoryControlServerLocator.setClientFailureCheckPeriod(long)public void setConnectionTTL(long connectionTTL)
setConnectionTTL in interface ConnectionFactoryControlServerLocator.setConnectionTTL(long)public void setCallTimeout(long callTimeout)
setCallTimeout in interface ConnectionFactoryControlServerLocator.setCallTimeout(long)public void setCallFailoverTimeout(long callTimeout)
setCallFailoverTimeout in interface ConnectionFactoryControlServerLocator.setCallFailoverTimeout(long)public void setConsumerWindowSize(int consumerWindowSize)
setConsumerWindowSize in interface ConnectionFactoryControlServerLocator.setConfirmationWindowSize(int)public void setConsumerMaxRate(int consumerMaxRate)
setConsumerMaxRate in interface ConnectionFactoryControlServerLocator.setConsumerMaxRate(int)public void setConfirmationWindowSize(int confirmationWindowSize)
setConfirmationWindowSize in interface ConnectionFactoryControlServerLocator.setConfirmationWindowSize(int)public void setProducerMaxRate(int producerMaxRate)
setProducerMaxRate in interface ConnectionFactoryControlServerLocator.setProducerMaxRate(int)public int getProducerWindowSize()
getProducerWindowSize in interface ConnectionFactoryControlServerLocator.getProducerWindowSize()public void setProducerWindowSize(int producerWindowSize)
setProducerWindowSize in interface ConnectionFactoryControlServerLocator.setProducerWindowSize(int)public void setCacheLargeMessagesClient(boolean cacheLargeMessagesClient)
setCacheLargeMessagesClient in interface ConnectionFactoryControlServerLocator.setCacheLargeMessagesClient(boolean)public boolean isCacheLargeMessagesClient()
isCacheLargeMessagesClient in interface ConnectionFactoryControlServerLocator.isCacheLargeMessagesClient()public void setMinLargeMessageSize(int minLargeMessageSize)
setMinLargeMessageSize in interface ConnectionFactoryControlServerLocator.setMinLargeMessageSize(int)public void setBlockOnNonDurableSend(boolean blockOnNonDurableSend)
setBlockOnNonDurableSend in interface ConnectionFactoryControlServerLocator.setBlockOnNonDurableSend(boolean)public void setBlockOnAcknowledge(boolean blockOnAcknowledge)
setBlockOnAcknowledge in interface ConnectionFactoryControlServerLocator.setBlockOnAcknowledge(boolean)public void setBlockOnDurableSend(boolean blockOnDurableSend)
setBlockOnDurableSend in interface ConnectionFactoryControlServerLocator.setBlockOnDurableSend(boolean)public void setAutoGroup(boolean autoGroup)
setAutoGroup in interface ConnectionFactoryControlServerLocator.setAutoGroup(boolean)public void setPreAcknowledge(boolean preAcknowledge)
setPreAcknowledge in interface ConnectionFactoryControlServerLocator.setPreAcknowledge(boolean)public void setMaxRetryInterval(long retryInterval)
setMaxRetryInterval in interface ConnectionFactoryControlServerLocator.setMaxRetryInterval(long)public void setRetryIntervalMultiplier(double retryIntervalMultiplier)
setRetryIntervalMultiplier in interface ConnectionFactoryControlServerLocator.setRetryIntervalMultiplier(double)public void setReconnectAttempts(int reconnectAttempts)
setReconnectAttempts in interface ConnectionFactoryControlServerLocator.setReconnectAttempts(int)public void setFailoverOnInitialConnection(boolean failover)
setFailoverOnInitialConnection in interface ConnectionFactoryControlServerLocator.setFailoverOnInitialConnection(boolean)public boolean isUseGlobalPools()
isUseGlobalPools in interface ConnectionFactoryControlServerLocator.isUseGlobalPools()public void setScheduledThreadPoolMaxSize(int scheduledThreadPoolMaxSize)
setScheduledThreadPoolMaxSize in interface ConnectionFactoryControlServerLocator.setScheduledThreadPoolMaxSize(int)public int getThreadPoolMaxSize()
getThreadPoolMaxSize in interface ConnectionFactoryControlServerLocator.getThreadPoolMaxSize()public void setThreadPoolMaxSize(int threadPoolMaxSize)
setThreadPoolMaxSize in interface ConnectionFactoryControlServerLocator.setThreadPoolMaxSize(int)public int getInitialMessagePacketSize()
getInitialMessagePacketSize in interface ConnectionFactoryControlServerLocator.getInitialMessagePacketSize()public void setGroupID(String groupID)
setGroupID in interface ConnectionFactoryControlServerLocator.setGroupID(String)public String getGroupID()
getGroupID in interface ConnectionFactoryControlServerLocator.getGroupID()public void setUseGlobalPools(boolean useGlobalPools)
setUseGlobalPools in interface ConnectionFactoryControlServerLocator.setUseGlobalPools(boolean)public int getScheduledThreadPoolMaxSize()
getScheduledThreadPoolMaxSize in interface ConnectionFactoryControlServerLocator.getScheduledThreadPoolMaxSize()public void setRetryInterval(long retryInterval)
setRetryInterval in interface ConnectionFactoryControlServerLocator.setRetryInterval(long)public long getMaxRetryInterval()
getMaxRetryInterval in interface ConnectionFactoryControlServerLocator.getMaxRetryInterval()public String getConnectionLoadBalancingPolicyClassName()
getConnectionLoadBalancingPolicyClassName in interface ConnectionFactoryControlServerLocator.getConnectionLoadBalancingPolicyClassName()public void setConnectionLoadBalancingPolicyClassName(String name)
setConnectionLoadBalancingPolicyClassName in interface ConnectionFactoryControlServerLocator.setConnectionLoadBalancingPolicyClassName(String)public TransportConfiguration[] getStaticConnectors()
getStaticConnectors in interface ConnectionFactoryControlServerLocator.getStaticTransportConfigurations()public DiscoveryGroupConfiguration getDiscoveryGroupConfiguration()
ConnectionFactoryControlgetDiscoveryGroupConfiguration in interface ConnectionFactoryControlpublic void addBinding(String binding) throws Exception
ConnectionFactoryControladdBinding in interface ConnectionFactoryControlExceptionpublic void removeBinding(String binding) throws Exception
ConnectionFactoryControlremoveBinding in interface ConnectionFactoryControlExceptionpublic long getCallTimeout()
getCallTimeout in interface ConnectionFactoryControlServerLocator.getCallTimeout()public long getCallFailoverTimeout()
getCallFailoverTimeout in interface ConnectionFactoryControlServerLocator.getCallFailoverTimeout()public int getConsumerMaxRate()
getConsumerMaxRate in interface ConnectionFactoryControlServerLocator.getConsumerMaxRate()public int getConsumerWindowSize()
getConsumerWindowSize in interface ConnectionFactoryControlServerLocator.getConsumerWindowSize()public int getProducerMaxRate()
getProducerMaxRate in interface ConnectionFactoryControlServerLocator.getProducerMaxRate()public int getConfirmationWindowSize()
getConfirmationWindowSize in interface ConnectionFactoryControlServerLocator.getConfirmationWindowSize()public int getDupsOKBatchSize()
ConnectionFactoryControlgetDupsOKBatchSize in interface ConnectionFactoryControlServerLocator.getAckBatchSize(),
Session.DUPS_OK_ACKNOWLEDGEpublic boolean isBlockOnAcknowledge()
isBlockOnAcknowledge in interface ConnectionFactoryControlServerLocator.isBlockOnAcknowledge()public boolean isBlockOnNonDurableSend()
isBlockOnNonDurableSend in interface ConnectionFactoryControlServerLocator.isBlockOnNonDurableSend()public boolean isBlockOnDurableSend()
isBlockOnDurableSend in interface ConnectionFactoryControlServerLocator.isBlockOnDurableSend()public boolean isPreAcknowledge()
isPreAcknowledge in interface ConnectionFactoryControlServerLocator.isPreAcknowledge()public String getName()
ConnectionFactoryControlgetName in interface ConnectionFactoryControlpublic long getConnectionTTL()
getConnectionTTL in interface ConnectionFactoryControlServerLocator.getConnectionTTL()public int getReconnectAttempts()
getReconnectAttempts in interface ConnectionFactoryControlServerLocator.getReconnectAttempts()public boolean isFailoverOnInitialConnection()
isFailoverOnInitialConnection in interface ConnectionFactoryControlServerLocator.isFailoverOnInitialConnection()public int getMinLargeMessageSize()
getMinLargeMessageSize in interface ConnectionFactoryControlServerLocator.getMinLargeMessageSize()public long getRetryInterval()
getRetryInterval in interface ConnectionFactoryControlServerLocator.getRetryInterval()public double getRetryIntervalMultiplier()
getRetryIntervalMultiplier in interface ConnectionFactoryControlServerLocator.getRetryIntervalMultiplier()public int getTransactionBatchSize()
ConnectionFactoryControlgetTransactionBatchSize in interface ConnectionFactoryControlServerLocator.getAckBatchSize()public void setProtocolManagerFactoryStr(String protocolManagerFactoryStr)
ConnectionFactoryControlsetProtocolManagerFactoryStr in interface ConnectionFactoryControlpublic String getProtocolManagerFactoryStr()
ConnectionFactoryControlgetProtocolManagerFactoryStr in interface ConnectionFactoryControlpublic boolean isAutoGroup()
isAutoGroup in interface ConnectionFactoryControlServerLocator.isAutoGroup()public MBeanInfo getMBeanInfo()
getMBeanInfo in interface DynamicMBeangetMBeanInfo in class StandardMBeanCopyright © 2018 The Apache Software Foundation. All rights reserved.