public class ConnectionFactoryProperties extends Object implements ConnectionFactoryOptions
Constructor and Description |
---|
ConnectionFactoryProperties() |
public List<String> getParsedConnectorClassNames()
public void setParsedConnectionParameters(List<Map<String,Object>> connectionParameters)
public Boolean isHA()
public void setHA(Boolean ha)
public Boolean isCacheLargeMessagesClient()
public void setCacheLargeMessagesClient(Boolean cacheLargeMessagesClient)
public Boolean isCompressLargeMessage()
public void setCompressLargeMessage(Boolean compressLargeMessage)
public String getConnectionLoadBalancingPolicyClassName()
public void setConnectionLoadBalancingPolicyClassName(String connectionLoadBalancingPolicyClassName)
public String getDiscoveryAddress()
public void setDiscoveryAddress(String discoveryAddress)
public Integer getDiscoveryPort()
public void setDiscoveryLocalBindAddress(String discoveryLocalBindAddress)
public String getDiscoveryLocalBindAddress()
public void setDiscoveryPort(Integer discoveryPort)
public Long getDiscoveryRefreshTimeout()
public void setDiscoveryRefreshTimeout(Long discoveryRefreshTimeout)
public Long getDiscoveryInitialWaitTimeout()
public void setDiscoveryInitialWaitTimeout(Long discoveryInitialWaitTimeout)
public String getClientID()
public void setClientID(String clientID)
public Integer getDupsOKBatchSize()
public void setDupsOKBatchSize(Integer dupsOKBatchSize)
public Integer getTransactionBatchSize()
public void setTransactionBatchSize(Integer transactionBatchSize)
public Long getClientFailureCheckPeriod()
public void setClientFailureCheckPeriod(Long clientFailureCheckPeriod)
public Long getConnectionTTL()
public void setConnectionTTL(Long connectionTTL)
public Long getCallTimeout()
public void setCallTimeout(Long callTimeout)
public Long getCallFailoverTimeout()
public void setCallFailoverTimeout(Long callFailoverTimeout)
public Integer getConsumerWindowSize()
public void setConsumerWindowSize(Integer consumerWindowSize)
public Integer getConsumerMaxRate()
public void setConsumerMaxRate(Integer consumerMaxRate)
public Integer getConfirmationWindowSize()
public void setConfirmationWindowSize(Integer confirmationWindowSize)
public Boolean isFailoverOnInitialConnection()
public void setFailoverOnInitialConnection(Boolean failoverOnInitialConnection)
public Integer getProducerMaxRate()
public void setProducerMaxRate(Integer producerMaxRate)
public Integer getProducerWindowSize()
public void setProducerWindowSize(Integer producerWindowSize)
public Integer getMinLargeMessageSize()
public void setMinLargeMessageSize(Integer minLargeMessageSize)
public Boolean isBlockOnAcknowledge()
public void setBlockOnAcknowledge(Boolean blockOnAcknowledge)
public Boolean isBlockOnNonDurableSend()
public void setBlockOnNonDurableSend(Boolean blockOnNonDurableSend)
public Boolean isBlockOnDurableSend()
public void setBlockOnDurableSend(Boolean blockOnDurableSend)
public Boolean isAutoGroup()
public void setAutoGroup(Boolean autoGroup)
public Boolean isPreAcknowledge()
public void setPreAcknowledge(Boolean preAcknowledge)
public Long getRetryInterval()
public void setRetryInterval(Long retryInterval)
public Double getRetryIntervalMultiplier()
public void setRetryIntervalMultiplier(Double retryIntervalMultiplier)
public Long getMaxRetryInterval()
public void setMaxRetryInterval(Long maxRetryInterval)
public Integer getReconnectAttempts()
public void setReconnectAttempts(Integer reconnectAttempts)
public Boolean isUseGlobalPools()
public void setUseGlobalPools(Boolean useGlobalPools)
public Integer getScheduledThreadPoolMaxSize()
public void setScheduledThreadPoolMaxSize(Integer scheduledThreadPoolMaxSize)
public Integer getThreadPoolMaxSize()
public void setThreadPoolMaxSize(Integer threadPoolMaxSize)
public String getGroupID()
public void setGroupID(String groupID)
public Integer getInitialConnectAttempts()
public void setInitialConnectAttempts(Integer initialConnectAttempts)
public Integer getInitialMessagePacketSize()
public void setInitialMessagePacketSize(Integer initialMessagePacketSize)
public String getJgroupsFile()
public void setJgroupsFile(String jgroupsFile)
public String getJgroupsChannelName()
public void setJgroupsChannelName(String jgroupsChannelName)
public String getProtocolManagerFactoryStr()
public void setProtocolManagerFactoryStr(String protocolManagerFactoryStr)
public String getDeserializationBlackList()
getDeserializationBlackList
in interface ConnectionFactoryOptions
public void setDeserializationBlackList(String deserializationBlackList)
setDeserializationBlackList
in interface ConnectionFactoryOptions
public String getDeserializationWhiteList()
getDeserializationWhiteList
in interface ConnectionFactoryOptions
public void setDeserializationWhiteList(String deserializationWhiteList)
setDeserializationWhiteList
in interface ConnectionFactoryOptions
public boolean isHasBeenUpdated()
Copyright © 2016 The Apache Software Foundation. All rights reserved.