org.apache.activemq.ra
Class ActiveMQManagedConnectionFactory

java.lang.Object
  extended by org.apache.activemq.ra.ActiveMQManagedConnectionFactory
All Implemented Interfaces:
java.io.Serializable, javax.resource.spi.ManagedConnectionFactory, javax.resource.spi.ResourceAdapterAssociation

public class ActiveMQManagedConnectionFactory
extends java.lang.Object
implements javax.resource.spi.ManagedConnectionFactory, javax.resource.spi.ResourceAdapterAssociation

Version:
$Revisio n$ TODO: Must override equals and hashCode (JCA spec 16.4)
See Also:
Serialized Form

Constructor Summary
ActiveMQManagedConnectionFactory()
           
 
Method Summary
 java.lang.Object createConnectionFactory()
          This is used when not running in an app server.
 java.lang.Object createConnectionFactory(javax.resource.spi.ConnectionManager manager)
           
 javax.resource.spi.ManagedConnection createManagedConnection(javax.security.auth.Subject subject, javax.resource.spi.ConnectionRequestInfo info)
           
 boolean equals(java.lang.Object object)
           
 java.lang.String getClientid()
           
 java.lang.Integer getDurableTopicPrefetch()
           
 java.lang.Long getInitialRedeliveryDelay()
           
 java.lang.Integer getInputStreamPrefetch()
           
 java.io.PrintWriter getLogWriter()
           
 java.lang.Integer getMaximumRedeliveries()
           
 java.lang.String getPassword()
           
 java.lang.Integer getQueueBrowserPrefetch()
           
 java.lang.Integer getQueuePrefetch()
           
 java.lang.Short getRedeliveryBackOffMultiplier()
           
 java.lang.Boolean getRedeliveryUseExponentialBackOff()
           
 javax.resource.spi.ResourceAdapter getResourceAdapter()
           
 java.lang.Integer getTopicPrefetch()
           
 java.lang.Boolean getUseInboundSession()
           
 java.lang.String getUserName()
           
 int hashCode()
           
 boolean isUseInboundSessionEnabled()
           
 javax.resource.spi.ManagedConnection matchManagedConnections(java.util.Set connections, javax.security.auth.Subject subject, javax.resource.spi.ConnectionRequestInfo info)
           
 void setAllPrefetchValues(java.lang.Integer i)
           
 void setClientid(java.lang.String clientid)
           
 void setDurableTopicPrefetch(java.lang.Integer durableTopicPrefetch)
           
 void setInitialRedeliveryDelay(java.lang.Long value)
           
 void setInputStreamPrefetch(java.lang.Integer inputStreamPrefetch)
           
 void setLogWriter(java.io.PrintWriter logWriter)
           
 void setMaximumRedeliveries(java.lang.Integer value)
           
 void setPassword(java.lang.String password)
           
 void setQueueBrowserPrefetch(java.lang.Integer queueBrowserPrefetch)
           
 void setQueuePrefetch(java.lang.Integer queuePrefetch)
           
 void setRedeliveryBackOffMultiplier(java.lang.Short value)
           
 void setRedeliveryUseExponentialBackOff(java.lang.Boolean value)
           
 void setResourceAdapter(javax.resource.spi.ResourceAdapter adapter)
           
 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, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ActiveMQManagedConnectionFactory

public ActiveMQManagedConnectionFactory()
Method Detail

setResourceAdapter

public void setResourceAdapter(javax.resource.spi.ResourceAdapter adapter)
                        throws javax.resource.ResourceException
Specified by:
setResourceAdapter in interface javax.resource.spi.ResourceAdapterAssociation
Throws:
javax.resource.ResourceException

equals

public boolean equals(java.lang.Object object)
Specified by:
equals in interface javax.resource.spi.ManagedConnectionFactory
Overrides:
equals in class java.lang.Object

hashCode

public int hashCode()
Specified by:
hashCode in interface javax.resource.spi.ManagedConnectionFactory
Overrides:
hashCode in class java.lang.Object

getResourceAdapter

public javax.resource.spi.ResourceAdapter getResourceAdapter()
Specified by:
getResourceAdapter in interface javax.resource.spi.ResourceAdapterAssociation

createConnectionFactory

public java.lang.Object createConnectionFactory(javax.resource.spi.ConnectionManager manager)
                                         throws javax.resource.ResourceException
Specified by:
createConnectionFactory in interface javax.resource.spi.ManagedConnectionFactory
Throws:
javax.resource.ResourceException
See Also:
ManagedConnectionFactory.createConnectionFactory(javax.resource.spi.ConnectionManager)

createConnectionFactory

public java.lang.Object createConnectionFactory()
                                         throws javax.resource.ResourceException
This is used when not running in an app server. For now we are creating a ConnectionFactory that has our SimpleConnectionManager implementation but it may be a better idea to not support this. The JMS api will have many quirks the user may not expect when running through the resource adapter.

Specified by:
createConnectionFactory in interface javax.resource.spi.ManagedConnectionFactory
Throws:
javax.resource.ResourceException
See Also:
ManagedConnectionFactory.createConnectionFactory()

createManagedConnection

public javax.resource.spi.ManagedConnection createManagedConnection(javax.security.auth.Subject subject,
                                                                    javax.resource.spi.ConnectionRequestInfo info)
                                                             throws javax.resource.ResourceException
Specified by:
createManagedConnection in interface javax.resource.spi.ManagedConnectionFactory
Throws:
javax.resource.ResourceException
See Also:
ManagedConnectionFactory.createManagedConnection(javax.security.auth.Subject, javax.resource.spi.ConnectionRequestInfo)

matchManagedConnections

public javax.resource.spi.ManagedConnection matchManagedConnections(java.util.Set connections,
                                                                    javax.security.auth.Subject subject,
                                                                    javax.resource.spi.ConnectionRequestInfo info)
                                                             throws javax.resource.ResourceException
Specified by:
matchManagedConnections in interface javax.resource.spi.ManagedConnectionFactory
Throws:
javax.resource.ResourceException
See Also:
ManagedConnectionFactory.matchManagedConnections(java.util.Set, javax.security.auth.Subject, javax.resource.spi.ConnectionRequestInfo)

setLogWriter

public void setLogWriter(java.io.PrintWriter logWriter)
                  throws javax.resource.ResourceException
Specified by:
setLogWriter in interface javax.resource.spi.ManagedConnectionFactory
Throws:
javax.resource.ResourceException
See Also:
ManagedConnectionFactory.setLogWriter(java.io.PrintWriter)

getLogWriter

public java.io.PrintWriter getLogWriter()
                                 throws javax.resource.ResourceException
Specified by:
getLogWriter in interface javax.resource.spi.ManagedConnectionFactory
Throws:
javax.resource.ResourceException
See Also:
ManagedConnectionFactory.getLogWriter()

getClientid

public java.lang.String getClientid()

getPassword

public java.lang.String getPassword()

getUserName

public java.lang.String getUserName()

setClientid

public void setClientid(java.lang.String clientid)

setPassword

public void setPassword(java.lang.String password)

setUserName

public void setUserName(java.lang.String userid)

getUseInboundSession

public java.lang.Boolean getUseInboundSession()

setUseInboundSession

public void setUseInboundSession(java.lang.Boolean useInboundSession)

isUseInboundSessionEnabled

public boolean isUseInboundSessionEnabled()

getInitialRedeliveryDelay

public java.lang.Long getInitialRedeliveryDelay()

getMaximumRedeliveries

public java.lang.Integer getMaximumRedeliveries()

getRedeliveryBackOffMultiplier

public java.lang.Short getRedeliveryBackOffMultiplier()

getRedeliveryUseExponentialBackOff

public java.lang.Boolean getRedeliveryUseExponentialBackOff()

setInitialRedeliveryDelay

public void setInitialRedeliveryDelay(java.lang.Long value)

setMaximumRedeliveries

public void setMaximumRedeliveries(java.lang.Integer value)

setRedeliveryBackOffMultiplier

public void setRedeliveryBackOffMultiplier(java.lang.Short value)

setRedeliveryUseExponentialBackOff

public void setRedeliveryUseExponentialBackOff(java.lang.Boolean value)

getDurableTopicPrefetch

public java.lang.Integer getDurableTopicPrefetch()

getInputStreamPrefetch

public java.lang.Integer getInputStreamPrefetch()

getQueueBrowserPrefetch

public java.lang.Integer getQueueBrowserPrefetch()

getQueuePrefetch

public java.lang.Integer getQueuePrefetch()

getTopicPrefetch

public java.lang.Integer getTopicPrefetch()

setAllPrefetchValues

public void setAllPrefetchValues(java.lang.Integer i)

setDurableTopicPrefetch

public void setDurableTopicPrefetch(java.lang.Integer durableTopicPrefetch)

setInputStreamPrefetch

public void setInputStreamPrefetch(java.lang.Integer inputStreamPrefetch)

setQueueBrowserPrefetch

public void setQueueBrowserPrefetch(java.lang.Integer queueBrowserPrefetch)

setQueuePrefetch

public void setQueuePrefetch(java.lang.Integer queuePrefetch)

setTopicPrefetch

public void setTopicPrefetch(java.lang.Integer topicPrefetch)


Copyright © 2010 Apache Software Foundation. All Rights Reserved.