public class ActiveMQConnectionSupport extends Object
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
log |
Constructor and Description |
---|
ActiveMQConnectionSupport() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.activemq.ActiveMQConnectionFactory |
createConnectionFactory(ActiveMQConnectionRequestInfo connectionRequestInfo,
MessageActivationSpec activationSpec)
Creates a factory for obtaining physical connections to an Active MQ
broker.
|
protected String |
defaultValue(String value,
String defaultValue) |
protected String |
emptyToNull(String value) |
String |
getClientid() |
Integer |
getDurableTopicPrefetch() |
ActiveMQConnectionRequestInfo |
getInfo()
Gets the connection request information.
|
Long |
getInitialRedeliveryDelay() |
Integer |
getInputStreamPrefetch() |
Integer |
getMaximumRedeliveries() |
Long |
getMaximumRedeliveryDelay() |
Integer |
getOptimizeDurableTopicPrefetch() |
String |
getPassword() |
Integer |
getQueueBrowserPrefetch() |
Integer |
getQueuePrefetch() |
Double |
getRedeliveryBackOffMultiplier() |
Boolean |
getRedeliveryUseExponentialBackOff() |
String |
getServerUrl() |
Integer |
getTopicPrefetch() |
Boolean |
getUseInboundSession() |
String |
getUserName() |
Boolean |
getUseSessionArgs() |
boolean |
isUseInboundSessionEnabled() |
boolean |
isUseSessionArgs() |
org.apache.activemq.ActiveMQConnection |
makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo)
Creates a new physical connection to an Active MQ broker identified by given
connection request information.
|
org.apache.activemq.ActiveMQConnection |
makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo,
org.apache.activemq.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(Object o1,
Object o2) |
void |
setAllPrefetchValues(Integer i) |
void |
setClientid(String clientid) |
void |
setDurableTopicPrefetch(Integer durableTopicPrefetch) |
protected void |
setInfo(ActiveMQConnectionRequestInfo connectionRequestInfo)
Sets the connection request information as a whole.
|
void |
setInitialRedeliveryDelay(Long value) |
void |
setInputStreamPrefetch(Integer inputStreamPrefetch) |
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)
if true, calls to managed connection factory.connection.createSession will
respect the passed in args.
|
protected org.slf4j.Logger log
public ActiveMQConnectionSupport()
protected org.apache.activemq.ActiveMQConnectionFactory createConnectionFactory(ActiveMQConnectionRequestInfo connectionRequestInfo, MessageActivationSpec activationSpec)
connectionRequestInfo
- the configuration request informationactivationSpec
- IllegalArgumentException
- if the server URL given in the
configuration information is not a valid URLpublic org.apache.activemq.ActiveMQConnection makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo) throws JMSException
connectionRequestInfo
- the connection request information identifying the broker and any
required connection parameters, e.g. username/passwordJMSException
- if the connection could not be establishedpublic org.apache.activemq.ActiveMQConnection makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo, org.apache.activemq.ActiveMQConnectionFactory connectionFactory) throws JMSException
connectionRequestInfo
- the connection request information containing the credentials to use
for the connection requestJMSException
- if the connection could not be establishedpublic ActiveMQConnectionRequestInfo getInfo()
protected void setInfo(ActiveMQConnectionRequestInfo connectionRequestInfo)
connectionRequestInfo
- the connection request informationprotected String emptyToNull(String value)
protected String defaultValue(String value, String defaultValue)
public String getClientid()
public void setClientid(String clientid)
clientid
- public String getPassword()
public void setPassword(String password)
password
- public String getServerUrl()
public void setServerUrl(String url)
url
- public void setTrustStore(String trustStore)
public void setTrustStorePassword(String trustStorePassword)
public void setKeyStore(String keyStore)
public void setKeyStorePassword(String keyStorePassword)
public void setKeyStoreKeyPassword(String keyStoreKeyPassword)
public String getUserName()
public void setUserName(String userid)
userid
- public Integer getDurableTopicPrefetch()
public void setOptimizeDurableTopicPrefetch(Integer optimizeDurableTopicPrefetch)
optimizeDurableTopicPrefetch
- public Integer getOptimizeDurableTopicPrefetch()
public void setDurableTopicPrefetch(Integer durableTopicPrefetch)
durableTopicPrefetch
- public Long getInitialRedeliveryDelay()
public void setInitialRedeliveryDelay(Long value)
value
- public Long getMaximumRedeliveryDelay()
public void setMaximumRedeliveryDelay(Long value)
value
- public Integer getInputStreamPrefetch()
public void setInputStreamPrefetch(Integer inputStreamPrefetch)
inputStreamPrefetch
- public Integer getMaximumRedeliveries()
public void setMaximumRedeliveries(Integer value)
value
- public Integer getQueueBrowserPrefetch()
public void setQueueBrowserPrefetch(Integer queueBrowserPrefetch)
queueBrowserPrefetch
- public Integer getQueuePrefetch()
public void setQueuePrefetch(Integer queuePrefetch)
queuePrefetch
- public Double getRedeliveryBackOffMultiplier()
public void setRedeliveryBackOffMultiplier(Double value)
value
- public Boolean getRedeliveryUseExponentialBackOff()
public void setRedeliveryUseExponentialBackOff(Boolean value)
value
- public Integer getTopicPrefetch()
public void setTopicPrefetch(Integer topicPrefetch)
topicPrefetch
- public void setAllPrefetchValues(Integer i)
i
- public boolean isUseInboundSessionEnabled()
public Boolean getUseInboundSession()
public void setUseInboundSession(Boolean useInboundSession)
useInboundSession
- public boolean isUseSessionArgs()
public Boolean getUseSessionArgs()
public void setUseSessionArgs(Boolean useSessionArgs)
useSessionArgs
- Copyright © 2005–2017 FuseSource, Corp.. All rights reserved.