public class ActiveMQConnectionSupport extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
log |
Constructor and Description |
---|
ActiveMQConnectionSupport() |
Modifier and Type | Method and Description |
---|---|
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) |
protected org.slf4j.Logger log
public ActiveMQConnectionSupport()
protected ActiveMQConnectionFactory createConnectionFactory(ActiveMQConnectionRequestInfo connectionRequestInfo)
connectionRequestInfo
- the configuration request informationjava.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/passwordjavax.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 requestjavax.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
- Copyright © 2005-2017. All Rights Reserved.