Package org.apache.activemq.artemis.ra

Class ActiveMQRAProperties

java.lang.Object

org.apache.activemq.artemis.ra.ConnectionFactoryProperties

org.apache.activemq.artemis.ra.ActiveMQRAProperties

All Implemented Interfaces:

Serializable, ConnectionFactoryOptions

public class ActiveMQRAProperties
extends ConnectionFactoryProperties
implements Serializable

The RA default properties - these are set in the ra.xml file

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	allowLocalTransactions
protected boolean	useTopologyForLoadBalancing

Constructor Summary

Constructors

Constructor	Description
ActiveMQRAProperties()

Method Summary

Modifier and Type	Method	Description
String	getCodec()
String	getJgroupsChannelLocatorClass()
String	getJgroupsChannelRefName()
Hashtable<?,?>	getParsedJndiParams()
String	getPassword()
String	getPasswordCodec()
int	getSetupAttempts()
long	getSetupInterval()
Boolean	getUseLocalTx()
String	getUserName()
void	init()
boolean	isAllowLocalTransactions()
boolean	isUseJNDI()
Boolean	isUseMaskedPassword()
boolean	isUseTopologyForLoadBalancing()
void	setAllowLocalTransactions(boolean allowLocalTransactions)
void	setJgroupsChannelLocatorClass(String jgroupsChannelLocatorClass)
void	setJgroupsChannelRefName(String jgroupsChannelRefName)
void	setParsedJndiParams(Hashtable<?,?> params)
void	setPassword(String password)	Set the password Based on UseMaskedPassword property, the password can be plain text or encoded string.
void	setPasswordCodec(String codecs)
void	setSetupAttempts(Integer setupAttempts)
void	setSetupInterval(Long setupInterval)
void	setUseJNDI(Boolean value)
void	setUseLocalTx(Boolean localTx)
void	setUseMaskedPassword(Boolean useMaskedPassword)
void	setUserName(String userName)
void	setUseTopologyForLoadBalancing(boolean useTopologyForLoadBalancing)
String	toString()

Methods inherited from class org.apache.activemq.artemis.ra.ConnectionFactoryProperties

equals, getCallFailoverTimeout, getCallTimeout, getClientFailureCheckPeriod, getClientID, getCompressionLevel, getConfirmationWindowSize, getConnectionLoadBalancingPolicyClassName, getConnectionTTL, getConsumerMaxRate, getConsumerWindowSize, getDeserializationAllowList, getDeserializationBlackList, getDeserializationDenyList, getDeserializationWhiteList, getDiscoveryAddress, getDiscoveryInitialWaitTimeout, getDiscoveryLocalBindAddress, getDiscoveryPort, getDiscoveryRefreshTimeout, getDupsOKBatchSize, getGroupID, getInitialConnectAttempts, getInitialMessagePacketSize, getJgroupsChannelName, getJgroupsFile, getMaxRetryInterval, getMinLargeMessageSize, getParsedConnectionParameters, getParsedConnectorClassNames, getProducerMaxRate, getProducerWindowSize, getProtocolManagerFactoryStr, getReconnectAttempts, getRetryInterval, getRetryIntervalMultiplier, getScheduledThreadPoolMaxSize, getThreadPoolMaxSize, getTransactionBatchSize, hashCode, isAutoGroup, isBlockOnAcknowledge, isBlockOnDurableSend, isBlockOnNonDurableSend, isCacheDestinations, isCacheLargeMessagesClient, isCompressLargeMessage, isEnable1xPrefixes, isEnableSharedClientID, isFailoverOnInitialConnection, isHA, isHasBeenUpdated, isPreAcknowledge, isUseGlobalPools, setAutoGroup, setBlockOnAcknowledge, setBlockOnDurableSend, setBlockOnNonDurableSend, setCacheDestinations, setCacheLargeMessagesClient, setCallFailoverTimeout, setCallTimeout, setClientFailureCheckPeriod, setClientID, setCompressionLevel, setCompressLargeMessage, setConfirmationWindowSize, setConnectionLoadBalancingPolicyClassName, setConnectionTTL, setConsumerMaxRate, setConsumerWindowSize, setDeserializationAllowList, setDeserializationBlackList, setDeserializationDenyList, setDeserializationWhiteList, setDiscoveryAddress, setDiscoveryInitialWaitTimeout, setDiscoveryLocalBindAddress, setDiscoveryPort, setDiscoveryRefreshTimeout, setDupsOKBatchSize, setEnable1xPrefixes, setEnableSharedClientID, setFailoverOnInitialConnection, setGroupID, setHA, setInitialConnectAttempts, setInitialMessagePacketSize, setJgroupsChannelName, setJgroupsFile, setMaxRetryInterval, setMinLargeMessageSize, setParsedConnectionParameters, setParsedConnectorClassNames, setPreAcknowledge, setProducerMaxRate, setProducerWindowSize, setProtocolManagerFactoryStr, setReconnectAttempts, setRetryInterval, setRetryIntervalMultiplier, setScheduledThreadPoolMaxSize, setThreadPoolMaxSize, setTransactionBatchSize, setUseGlobalPools

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

allowLocalTransactions

protected boolean allowLocalTransactions

useTopologyForLoadBalancing

protected boolean useTopologyForLoadBalancing

Constructor Details

ActiveMQRAProperties

public ActiveMQRAProperties()

Method Details

getUserName

public String getUserName()

setUserName

public void setUserName(String userName)

getPassword

public String getPassword()

setPassword

public void setPassword(String password)

Set the password Based on UseMaskedPassword property, the password can be plain text or encoded string. However we cannot decide which is the case at this moment, because we don't know when the UseMaskedPassword and PasswordCodec are loaded. So for the moment we just save the password.

Parameters:

password - The value

isUseJNDI

public boolean isUseJNDI()

setUseJNDI

public void setUseJNDI(Boolean value)

getParsedJndiParams

public Hashtable<?,?> getParsedJndiParams()

setParsedJndiParams

public void setParsedJndiParams(Hashtable<?,?> params)

getUseLocalTx

public Boolean getUseLocalTx()

setUseLocalTx

public void setUseLocalTx(Boolean localTx)

getSetupAttempts

public int getSetupAttempts()

setSetupAttempts

public void setSetupAttempts(Integer setupAttempts)

getSetupInterval

public long getSetupInterval()

setSetupInterval

public void setSetupInterval(Long setupInterval)

isUseMaskedPassword

public Boolean isUseMaskedPassword()

setUseMaskedPassword

public void setUseMaskedPassword(Boolean useMaskedPassword)

getPasswordCodec

public String getPasswordCodec()

setPasswordCodec

public void setPasswordCodec(String codecs)

toString

public String toString()

Overrides:

toString in class Object

init

public void init()
          throws ActiveMQException

Throws:

ActiveMQException

setUseTopologyForLoadBalancing

public void setUseTopologyForLoadBalancing(boolean useTopologyForLoadBalancing)

isUseTopologyForLoadBalancing

public boolean isUseTopologyForLoadBalancing()

getCodec

public String getCodec()

getJgroupsChannelLocatorClass

public String getJgroupsChannelLocatorClass()

setJgroupsChannelLocatorClass

public void setJgroupsChannelLocatorClass(String jgroupsChannelLocatorClass)

getJgroupsChannelRefName

public String getJgroupsChannelRefName()

setJgroupsChannelRefName

public void setJgroupsChannelRefName(String jgroupsChannelRefName)

isAllowLocalTransactions

public boolean isAllowLocalTransactions()

setAllowLocalTransactions

public void setAllowLocalTransactions(boolean allowLocalTransactions)