|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.ra.ActiveMQConnectionSupport
public class ActiveMQConnectionSupport
Abstract base class providing support for creating physical connections to an ActiveMQ instance.
Field Summary | |
---|---|
protected org.slf4j.Logger |
log
|
Constructor Summary | |
---|---|
ActiveMQConnectionSupport()
|
Method Summary | |
---|---|
protected ActiveMQConnectionFactory |
createConnectionFactory(ActiveMQConnectionRequestInfo connectionRequestInfo)
Creates a factory for obtaining physical connections to an Active MQ broker. |
protected java.lang.String |
defaultValue(java.lang.String value,
java.lang.String defaultValue)
|
protected java.lang.String |
emptyToNull(java.lang.String value)
|
java.lang.String |
getClientid()
|
java.lang.Integer |
getDurableTopicPrefetch()
|
ActiveMQConnectionRequestInfo |
getInfo()
Gets the connection request information. |
java.lang.Long |
getInitialRedeliveryDelay()
|
java.lang.Integer |
getInputStreamPrefetch()
|
java.lang.Integer |
getMaximumRedeliveries()
|
java.lang.Long |
getMaximumRedeliveryDelay()
|
java.lang.String |
getPassword()
|
java.lang.Integer |
getQueueBrowserPrefetch()
|
java.lang.Integer |
getQueuePrefetch()
|
java.lang.Double |
getRedeliveryBackOffMultiplier()
|
java.lang.Boolean |
getRedeliveryUseExponentialBackOff()
|
java.lang.String |
getServerUrl()
|
java.lang.Integer |
getTopicPrefetch()
|
java.lang.Boolean |
getUseInboundSession()
|
java.lang.String |
getUserName()
|
boolean |
isUseInboundSessionEnabled()
|
ActiveMQConnection |
makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo)
Creates a new physical connection to an Active MQ broker identified by given connection request information. |
ActiveMQConnection |
makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo,
ActiveMQConnectionFactory connectionFactory)
Creates a new physical connection to an Active MQ broker using a given connection factory and credentials supplied in connection request information. |
protected boolean |
notEqual(java.lang.Object o1,
java.lang.Object o2)
|
void |
setAllPrefetchValues(java.lang.Integer i)
|
void |
setClientid(java.lang.String clientid)
|
void |
setDurableTopicPrefetch(java.lang.Integer durableTopicPrefetch)
|
protected void |
setInfo(ActiveMQConnectionRequestInfo connectionRequestInfo)
Sets the connection request information as a whole. |
void |
setInitialRedeliveryDelay(java.lang.Long value)
|
void |
setInputStreamPrefetch(java.lang.Integer inputStreamPrefetch)
|
void |
setMaximumRedeliveries(java.lang.Integer value)
|
void |
setMaximumRedeliveryDelay(java.lang.Long value)
|
void |
setPassword(java.lang.String password)
|
void |
setQueueBrowserPrefetch(java.lang.Integer queueBrowserPrefetch)
|
void |
setQueuePrefetch(java.lang.Integer queuePrefetch)
|
void |
setRedeliveryBackOffMultiplier(java.lang.Double value)
|
void |
setRedeliveryUseExponentialBackOff(java.lang.Boolean value)
|
void |
setServerUrl(java.lang.String url)
|
void |
setTopicPrefetch(java.lang.Integer topicPrefetch)
|
void |
setUseInboundSession(java.lang.Boolean useInboundSession)
|
void |
setUserName(java.lang.String userid)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected org.slf4j.Logger log
Constructor Detail |
---|
public ActiveMQConnectionSupport()
Method Detail |
---|
protected ActiveMQConnectionFactory createConnectionFactory(ActiveMQConnectionRequestInfo connectionRequestInfo)
connectionRequestInfo
- the configuration request information
java.lang.IllegalArgumentException
- if the server URL given in the
configuration information is not a valid URLpublic ActiveMQConnection makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo) throws javax.jms.JMSException
connectionRequestInfo
- the connection request information identifying the broker and any
required connection parameters, e.g. username/password
javax.jms.JMSException
- if the connection could not be establishedpublic ActiveMQConnection makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo, ActiveMQConnectionFactory connectionFactory) throws javax.jms.JMSException
connectionRequestInfo
- the connection request information containing the credentials to use
for the connection request
javax.jms.JMSException
- if the connection could not be establishedpublic ActiveMQConnectionRequestInfo getInfo()
protected void setInfo(ActiveMQConnectionRequestInfo connectionRequestInfo)
connectionRequestInfo
- the connection request informationprotected boolean notEqual(java.lang.Object o1, java.lang.Object o2)
protected java.lang.String emptyToNull(java.lang.String value)
protected java.lang.String defaultValue(java.lang.String value, java.lang.String defaultValue)
public java.lang.String getClientid()
public void setClientid(java.lang.String clientid)
clientid
- public java.lang.String getPassword()
public void setPassword(java.lang.String password)
password
- public java.lang.String getServerUrl()
public void setServerUrl(java.lang.String url)
url
- public java.lang.String getUserName()
public void setUserName(java.lang.String userid)
userid
- public java.lang.Integer getDurableTopicPrefetch()
public void setDurableTopicPrefetch(java.lang.Integer durableTopicPrefetch)
durableTopicPrefetch
- public java.lang.Long getInitialRedeliveryDelay()
public void setInitialRedeliveryDelay(java.lang.Long value)
value
- public java.lang.Long getMaximumRedeliveryDelay()
public void setMaximumRedeliveryDelay(java.lang.Long value)
value
- public java.lang.Integer getInputStreamPrefetch()
public void setInputStreamPrefetch(java.lang.Integer inputStreamPrefetch)
inputStreamPrefetch
- public java.lang.Integer getMaximumRedeliveries()
public void setMaximumRedeliveries(java.lang.Integer value)
value
- public java.lang.Integer getQueueBrowserPrefetch()
public void setQueueBrowserPrefetch(java.lang.Integer queueBrowserPrefetch)
queueBrowserPrefetch
- public java.lang.Integer getQueuePrefetch()
public void setQueuePrefetch(java.lang.Integer queuePrefetch)
queuePrefetch
- public java.lang.Double getRedeliveryBackOffMultiplier()
public void setRedeliveryBackOffMultiplier(java.lang.Double value)
value
- public java.lang.Boolean getRedeliveryUseExponentialBackOff()
public void setRedeliveryUseExponentialBackOff(java.lang.Boolean value)
value
- public java.lang.Integer getTopicPrefetch()
public void setTopicPrefetch(java.lang.Integer topicPrefetch)
topicPrefetch
- public void setAllPrefetchValues(java.lang.Integer i)
i
- public boolean isUseInboundSessionEnabled()
public java.lang.Boolean getUseInboundSession()
public void setUseInboundSession(java.lang.Boolean useInboundSession)
useInboundSession
-
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |