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)
connectionRequestInfo
- the configuration request informationIllegalArgumentException
- 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 getUserName()
public void setUserName(String userid)
userid
- public Integer getDurableTopicPrefetch()
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
- Copyright © 2005–2016. All rights reserved.