org.apache.activemq.ra
Class ActiveMQConnectionSupport

java.lang.Object
  extended by org.apache.activemq.ra.ActiveMQConnectionSupport
Direct Known Subclasses:
ActiveMQManagedConnectionFactory, ActiveMQResourceAdapter

public class ActiveMQConnectionSupport
extends java.lang.Object

Abstract base class providing support for creating physical connections to an ActiveMQ instance.


Field Summary
protected  org.slf4j.Logger log
           
 
Constructor Summary
ActiveMQConnectionSupport()
           
 
Method Summary
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)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

protected org.slf4j.Logger log
Constructor Detail

ActiveMQConnectionSupport

public ActiveMQConnectionSupport()
Method Detail

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:
java.lang.IllegalArgumentException - if the server URL given in the configuration information is not a valid URL

makeConnection

public ActiveMQConnection makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo)
                                  throws javax.jms.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:
javax.jms.JMSException - if the connection could not be established

makeConnection

public ActiveMQConnection makeConnection(ActiveMQConnectionRequestInfo connectionRequestInfo,
                                         ActiveMQConnectionFactory connectionFactory)
                                  throws javax.jms.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:
javax.jms.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(java.lang.Object o1,
                           java.lang.Object o2)

emptyToNull

protected java.lang.String emptyToNull(java.lang.String value)

defaultValue

protected java.lang.String defaultValue(java.lang.String value,
                                        java.lang.String defaultValue)

getClientid

public java.lang.String getClientid()
Returns:
client id

setClientid

public void setClientid(java.lang.String clientid)
Parameters:
clientid -

getPassword

public java.lang.String getPassword()
Returns:
password

setPassword

public void setPassword(java.lang.String password)
Parameters:
password -

getServerUrl

public java.lang.String getServerUrl()
Returns:
server URL

setServerUrl

public void setServerUrl(java.lang.String url)
Parameters:
url -

getUserName

public java.lang.String getUserName()
Returns:
user name

setUserName

public void setUserName(java.lang.String userid)
Parameters:
userid -

getDurableTopicPrefetch

public java.lang.Integer getDurableTopicPrefetch()
Returns:
durable topic prefetch

setDurableTopicPrefetch

public void setDurableTopicPrefetch(java.lang.Integer durableTopicPrefetch)
Parameters:
durableTopicPrefetch -

getInitialRedeliveryDelay

public java.lang.Long getInitialRedeliveryDelay()
Returns:
initial redelivery delay

setInitialRedeliveryDelay

public void setInitialRedeliveryDelay(java.lang.Long value)
Parameters:
value -

getMaximumRedeliveryDelay

public java.lang.Long getMaximumRedeliveryDelay()
Returns:
initial redelivery delay

setMaximumRedeliveryDelay

public void setMaximumRedeliveryDelay(java.lang.Long value)
Parameters:
value -

getInputStreamPrefetch

public java.lang.Integer getInputStreamPrefetch()
Returns:
input stream prefetch

setInputStreamPrefetch

public void setInputStreamPrefetch(java.lang.Integer inputStreamPrefetch)
Parameters:
inputStreamPrefetch -

getMaximumRedeliveries

public java.lang.Integer getMaximumRedeliveries()
Returns:
maximum redeliveries

setMaximumRedeliveries

public void setMaximumRedeliveries(java.lang.Integer value)
Parameters:
value -

getQueueBrowserPrefetch

public java.lang.Integer getQueueBrowserPrefetch()
Returns:
queue browser prefetch

setQueueBrowserPrefetch

public void setQueueBrowserPrefetch(java.lang.Integer queueBrowserPrefetch)
Parameters:
queueBrowserPrefetch -

getQueuePrefetch

public java.lang.Integer getQueuePrefetch()
Returns:
queue prefetch

setQueuePrefetch

public void setQueuePrefetch(java.lang.Integer queuePrefetch)
Parameters:
queuePrefetch -

getRedeliveryBackOffMultiplier

public java.lang.Double getRedeliveryBackOffMultiplier()
Returns:
redelivery backoff multiplier

setRedeliveryBackOffMultiplier

public void setRedeliveryBackOffMultiplier(java.lang.Double value)
Parameters:
value -

getRedeliveryUseExponentialBackOff

public java.lang.Boolean getRedeliveryUseExponentialBackOff()
Returns:
redelivery use exponential backoff

setRedeliveryUseExponentialBackOff

public void setRedeliveryUseExponentialBackOff(java.lang.Boolean value)
Parameters:
value -

getTopicPrefetch

public java.lang.Integer getTopicPrefetch()
Returns:
topic prefetch

setTopicPrefetch

public void setTopicPrefetch(java.lang.Integer topicPrefetch)
Parameters:
topicPrefetch -

setAllPrefetchValues

public void setAllPrefetchValues(java.lang.Integer i)
Parameters:
i -

isUseInboundSessionEnabled

public boolean isUseInboundSessionEnabled()
Returns:
use inbound session enabled

getUseInboundSession

public java.lang.Boolean getUseInboundSession()
Returns:
use inbound session

setUseInboundSession

public void setUseInboundSession(java.lang.Boolean useInboundSession)
Parameters:
useInboundSession -


Copyright © 2005-2016. All Rights Reserved.