public class ActiveMQConnectionSupport extends Object
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
log |
Constructor and Description |
---|
ActiveMQConnectionSupport() |
protected org.slf4j.Logger log
public ActiveMQConnectionSupport()
protected 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 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 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 String getTrustStore()
public void setTrustStore(String trustStore)
public String getTrustStorePassword()
public void setTrustStorePassword(String trustStorePassword)
public String getKeyStore()
public void setKeyStore(String keyStore)
public String getKeyStorePassword()
public void setKeyStorePassword(String keyStorePassword)
public String getKeyStoreKeyPassword()
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
- @Deprecated public Integer getInputStreamPrefetch()
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–2019 The Apache Software Foundation. All rights reserved.