org.apache.activemq.ra

Class ActiveMQConnectionRequestInfo

java.lang.Object

org.apache.activemq.ra.ActiveMQConnectionRequestInfo

All Implemented Interfaces:

Serializable, Cloneable, javax.resource.spi.ConnectionRequestInfo

public class ActiveMQConnectionRequestInfo
extends Object
implements javax.resource.spi.ConnectionRequestInfo, Serializable, Cloneable

Must override equals and hashCode (JCA spec 16.4)

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
ActiveMQConnectionRequestInfo()

Method Summary

Modifier and Type	Method and Description
void	configure(ActiveMQConnectionFactory factory, MessageActivationSpec activationSpec) Configures the given connection factory
ActiveMQConnectionRequestInfo	copy()
protected String	defaultValue(String value, String defaultValue)
boolean	equals(Object o)
String	getClientid()
Integer	getDurableTopicPrefetch()
Long	getInitialRedeliveryDelay()
Integer	getInputStreamPrefetch() Deprecated.
String	getKeyStore()
String	getKeyStoreKeyPassword()
String	getKeyStorePassword()
Integer	getMaximumRedeliveries()
Long	getMaximumRedeliveryDelay()
Integer	getOptimizeDurableTopicPrefetch()
String	getPassword()
Integer	getQueueBrowserPrefetch()
Integer	getQueuePrefetch()
Double	getRedeliveryBackOffMultiplier()
Boolean	getRedeliveryUseExponentialBackOff()
String	getServerUrl()
Integer	getTopicPrefetch()
String	getTrustStore()
String	getTrustStorePassword()
Boolean	getUseInboundSession()
String	getUserName()
Boolean	getUseSessionArgs()
int	hashCode()
boolean	isConnectionFactoryConfigured() Returns true if this object will configure an ActiveMQConnectionFactory in any way
boolean	isUseInboundSessionEnabled()
boolean	isUseSessionArgs()
ActiveMQPrefetchPolicy	prefetchPolicy() Returns the prefetch policy; not using bean properties to avoid breaking compatibility with JCA configuration in J2EE
RedeliveryPolicy	redeliveryPolicy() Returns the redelivery policy; not using bean properties to avoid breaking compatibility with JCA configuration in J2EE
void	setAllPrefetchValues(Integer i)
void	setClientid(String clientid)
void	setDurableTopicPrefetch(Integer durableTopicPrefetch)
void	setInitialRedeliveryDelay(Long value)
void	setKeyStore(String keyStore)
void	setKeyStoreKeyPassword(String keyStoreKeyPassword)
void	setKeyStorePassword(String keyStorePassword)
void	setMaximumRedeliveries(Integer value)
void	setMaximumRedeliveryDelay(Long value)
void	setOptimizeDurableTopicPrefetch(Integer optimizeDurableTopicPrefetch)
void	setPassword(String password)
void	setQueueBrowserPrefetch(Integer queueBrowserPrefetch)
void	setQueuePrefetch(Integer queuePrefetch)
void	setRedeliveryBackOffMultiplier(Double value)
void	setRedeliveryUseExponentialBackOff(Boolean value)
void	setServerUrl(String url)
void	setTopicPrefetch(Integer topicPrefetch)
void	setTrustStore(String trustStore)
void	setTrustStorePassword(String trustStorePassword)
void	setUseInboundSession(Boolean useInboundSession)
void	setUserName(String userid)
void	setUseSessionArgs(Boolean useSessionArgs)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

log

protected org.slf4j.Logger log

Constructor Detail

ActiveMQConnectionRequestInfo

public ActiveMQConnectionRequestInfo()

Method Detail

copy

public ActiveMQConnectionRequestInfo copy()

isConnectionFactoryConfigured

public boolean isConnectionFactoryConfigured()

Returns true if this object will configure an ActiveMQConnectionFactory in any way

configure

public void configure(ActiveMQConnectionFactory factory,
                      MessageActivationSpec activationSpec)

Configures the given connection factory

hashCode

public int hashCode()

Specified by:

hashCode in interface javax.resource.spi.ConnectionRequestInfo

Overrides:

hashCode in class Object

See Also:

ConnectionRequestInfo.hashCode()

equals

public boolean equals(Object o)

Specified by:

equals in interface javax.resource.spi.ConnectionRequestInfo

Overrides:

equals in class Object

See Also:

ConnectionRequestInfo.equals(java.lang.Object)

getServerUrl

public String getServerUrl()

Returns:

Returns the url.

setServerUrl

public void setServerUrl(String url)

Parameters:

url - The url to set.

getPassword

public String getPassword()

Returns:

Returns the password.

setPassword

public void setPassword(String password)

Parameters:

password - The password to set.

getUserName

public String getUserName()

Returns:

Returns the userid.

setUserName

public void setUserName(String userid)

Parameters:

userid - The userid to set.

getClientid

public String getClientid()

Returns:

Returns the clientid.

setClientid

public void setClientid(String clientid)

Parameters:

clientid - The clientid to set.

getTrustStore

public String getTrustStore()

setTrustStore

public void setTrustStore(String trustStore)

getTrustStorePassword

public String getTrustStorePassword()

setTrustStorePassword

public void setTrustStorePassword(String trustStorePassword)

getKeyStore

public String getKeyStore()

setKeyStore

public void setKeyStore(String keyStore)

getKeyStorePassword

public String getKeyStorePassword()

setKeyStorePassword

public void setKeyStorePassword(String keyStorePassword)

getKeyStoreKeyPassword

public String getKeyStoreKeyPassword()

setKeyStoreKeyPassword

public void setKeyStoreKeyPassword(String keyStoreKeyPassword)

toString

public String toString()

Overrides:

toString in class Object

getUseInboundSession

public Boolean getUseInboundSession()

setUseInboundSession

public void setUseInboundSession(Boolean useInboundSession)

isUseInboundSessionEnabled

public boolean isUseInboundSessionEnabled()

getRedeliveryBackOffMultiplier

public Double getRedeliveryBackOffMultiplier()

getInitialRedeliveryDelay

public Long getInitialRedeliveryDelay()

getMaximumRedeliveryDelay

public Long getMaximumRedeliveryDelay()

getMaximumRedeliveries

public Integer getMaximumRedeliveries()

getRedeliveryUseExponentialBackOff

public Boolean getRedeliveryUseExponentialBackOff()

setRedeliveryBackOffMultiplier

public void setRedeliveryBackOffMultiplier(Double value)

setInitialRedeliveryDelay

public void setInitialRedeliveryDelay(Long value)

setMaximumRedeliveryDelay

public void setMaximumRedeliveryDelay(Long value)

setMaximumRedeliveries

public void setMaximumRedeliveries(Integer value)

setRedeliveryUseExponentialBackOff

public void setRedeliveryUseExponentialBackOff(Boolean value)

getDurableTopicPrefetch

public Integer getDurableTopicPrefetch()

getOptimizeDurableTopicPrefetch

public Integer getOptimizeDurableTopicPrefetch()

getInputStreamPrefetch

@Deprecated
public Integer getInputStreamPrefetch()

Deprecated.

getQueueBrowserPrefetch

public Integer getQueueBrowserPrefetch()

getQueuePrefetch

public Integer getQueuePrefetch()

getTopicPrefetch

public Integer getTopicPrefetch()

setAllPrefetchValues

public void setAllPrefetchValues(Integer i)

setDurableTopicPrefetch

public void setDurableTopicPrefetch(Integer durableTopicPrefetch)

setOptimizeDurableTopicPrefetch

public void setOptimizeDurableTopicPrefetch(Integer optimizeDurableTopicPrefetch)

setQueueBrowserPrefetch

public void setQueueBrowserPrefetch(Integer queueBrowserPrefetch)

setQueuePrefetch

public void setQueuePrefetch(Integer queuePrefetch)

setTopicPrefetch

public void setTopicPrefetch(Integer topicPrefetch)

redeliveryPolicy

public RedeliveryPolicy redeliveryPolicy()

Returns the redelivery policy; not using bean properties to avoid breaking compatibility with JCA configuration in J2EE

prefetchPolicy

public ActiveMQPrefetchPolicy prefetchPolicy()

Returns the prefetch policy; not using bean properties to avoid breaking compatibility with JCA configuration in J2EE

isUseSessionArgs

public boolean isUseSessionArgs()

getUseSessionArgs

public Boolean getUseSessionArgs()

setUseSessionArgs

public void setUseSessionArgs(Boolean useSessionArgs)

defaultValue

protected String defaultValue(String value,
                              String defaultValue)