org.apache.activemq.ra
Class ActiveMQConnectionSupport
java.lang.Object
org.apache.activemq.ra.ActiveMQConnectionSupport
- Direct Known Subclasses:
- ActiveMQManagedConnectionFactory, ActiveMQResourceAdapter
public class ActiveMQConnectionSupport
- extends Object
Abstract base class providing support for creating physical
connections to an ActiveMQ instance.
- Version:
- $Revision$
Field Summary |
protected Log |
log
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
log
protected Log log
ActiveMQConnectionSupport
public ActiveMQConnectionSupport()
createConnectionFactory
protected ActiveMQConnectionFactory createConnectionFactory(ActiveMQConnectionRequestInfo connectionRequestInfo)
- Creates a factory for obtaining physical connections to an Active MQ
broker. The factory is configured with the given configuration information.
- Parameters:
connectionRequestInfo
- the configuration request information
- Returns:
- the connection factory
- Throws:
IllegalArgumentException
- if the server URL given in the
configuration information is not a valid URL
makeConnection
public ActiveMQConnection makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo)
throws JMSException
- Creates a new physical connection to an Active MQ broker identified by given
connection request information.
- Parameters:
connectionRequestInfo
- the connection request information identifying the broker and any
required connection parameters, e.g. username/password
- Returns:
- the physical connection
- Throws:
JMSException
- if the connection could not be established
makeConnection
public ActiveMQConnection makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo,
ActiveMQConnectionFactory connectionFactory)
throws JMSException
- Creates a new physical connection to an Active MQ broker using a given
connection factory and credentials supplied in connection request information.
- Parameters:
connectionRequestInfo
- the connection request information containing the credentials to use
for the connection request
- Returns:
- the physical connection
- Throws:
JMSException
- if the connection could not be established
getInfo
public ActiveMQConnectionRequestInfo getInfo()
- Gets the connection request information.
- Returns:
- the connection request information
setInfo
protected void setInfo(ActiveMQConnectionRequestInfo connectionRequestInfo)
- Sets the connection request information as a whole.
- Parameters:
connectionRequestInfo
- the connection request information
notEqual
protected boolean notEqual(Object o1,
Object o2)
emptyToNull
protected String emptyToNull(String value)
defaultValue
protected String defaultValue(String value,
String defaultValue)
getClientid
public String getClientid()
- Returns:
- client id
setClientid
public void setClientid(String clientid)
- Parameters:
clientid
-
getPassword
public String getPassword()
- Returns:
- password
setPassword
public void setPassword(String password)
- Parameters:
password
-
getServerUrl
public String getServerUrl()
- Returns:
- server URL
setServerUrl
public void setServerUrl(String url)
- Parameters:
url
-
getUserName
public String getUserName()
- Returns:
- user name
setUserName
public void setUserName(String userid)
- Parameters:
userid
-
getDurableTopicPrefetch
public Integer getDurableTopicPrefetch()
- Returns:
- durable topic prefetch
setDurableTopicPrefetch
public void setDurableTopicPrefetch(Integer durableTopicPrefetch)
- Parameters:
durableTopicPrefetch
-
getInitialRedeliveryDelay
public Long getInitialRedeliveryDelay()
- Returns:
- initial redelivery delay
setInitialRedeliveryDelay
public void setInitialRedeliveryDelay(Long value)
- Parameters:
value
-
getInputStreamPrefetch
public Integer getInputStreamPrefetch()
- Returns:
- input stream prefetch
setInputStreamPrefetch
public void setInputStreamPrefetch(Integer inputStreamPrefetch)
- Parameters:
inputStreamPrefetch
-
getMaximumRedeliveries
public Integer getMaximumRedeliveries()
- Returns:
- maximum redeliveries
setMaximumRedeliveries
public void setMaximumRedeliveries(Integer value)
- Parameters:
value
-
getQueueBrowserPrefetch
public Integer getQueueBrowserPrefetch()
- Returns:
- queue browser prefetch
setQueueBrowserPrefetch
public void setQueueBrowserPrefetch(Integer queueBrowserPrefetch)
- Parameters:
queueBrowserPrefetch
-
getQueuePrefetch
public Integer getQueuePrefetch()
- Returns:
- queue prefetch
setQueuePrefetch
public void setQueuePrefetch(Integer queuePrefetch)
- Parameters:
queuePrefetch
-
getRedeliveryBackOffMultiplier
public Double getRedeliveryBackOffMultiplier()
- Returns:
- redelivery backoff multiplier
setRedeliveryBackOffMultiplier
public void setRedeliveryBackOffMultiplier(Short value)
- Parameters:
value
-
getRedeliveryUseExponentialBackOff
public Boolean getRedeliveryUseExponentialBackOff()
- Returns:
- redelivery use exponential backoff
setRedeliveryUseExponentialBackOff
public void setRedeliveryUseExponentialBackOff(Boolean value)
- Parameters:
value
-
getTopicPrefetch
public Integer getTopicPrefetch()
- Returns:
- topic prefetch
setTopicPrefetch
public void setTopicPrefetch(Integer topicPrefetch)
- Parameters:
topicPrefetch
-
setAllPrefetchValues
public void setAllPrefetchValues(Integer i)
- Parameters:
i
-
isUseInboundSessionEnabled
public boolean isUseInboundSessionEnabled()
- Returns:
- use inbound session enabled
getUseInboundSession
public Boolean getUseInboundSession()
- Returns:
- use inbound session
setUseInboundSession
public void setUseInboundSession(Boolean useInboundSession)
- Parameters:
useInboundSession
-
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.