Package org.apache.activemq.ra

Class ActiveMQManagedConnectionFactory

java.lang.Object

org.apache.activemq.ra.ActiveMQConnectionSupport

org.apache.activemq.ra.ActiveMQManagedConnectionFactory

All Implemented Interfaces:

jakarta.resource.spi.ManagedConnectionFactory, jakarta.resource.spi.ResourceAdapterAssociation, Serializable

public class ActiveMQManagedConnectionFactory
extends ActiveMQConnectionSupport
implements jakarta.resource.spi.ManagedConnectionFactory, jakarta.resource.spi.ResourceAdapterAssociation

Version:

$Revisio n$ TODO: Must override equals and hashCode (JCA spec 16.4)

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.apache.activemq.ra.ActiveMQConnectionSupport

log

Constructor Summary

Constructors

Constructor	Description
ActiveMQManagedConnectionFactory()

Method Summary

Modifier and Type	Method	Description
Object	createConnectionFactory()	This is used when not running in an app server.
Object	createConnectionFactory(jakarta.resource.spi.ConnectionManager manager)
jakarta.resource.spi.ManagedConnection	createManagedConnection(Subject subject, jakarta.resource.spi.ConnectionRequestInfo connectionRequestInfo)
boolean	equals(Object object)
PrintWriter	getLogWriter()
jakarta.resource.spi.ResourceAdapter	getResourceAdapter()
int	hashCode()
jakarta.resource.spi.ManagedConnection	matchManagedConnections(Set connections, Subject subject, jakarta.resource.spi.ConnectionRequestInfo connectionRequestInfo)
void	setLogWriter(PrintWriter aLogWriter)
void	setResourceAdapter(jakarta.resource.spi.ResourceAdapter adapter)

Methods inherited from class org.apache.activemq.ra.ActiveMQConnectionSupport

createConnectionFactory, defaultValue, emptyToNull, getClientid, getDurableTopicPrefetch, getInfo, getInitialRedeliveryDelay, getInputStreamPrefetch, getKeyStore, getKeyStoreKeyPassword, getKeyStorePassword, getMaximumRedeliveries, getMaximumRedeliveryDelay, getOptimizeDurableTopicPrefetch, getPassword, getQueueBrowserPrefetch, getQueuePrefetch, getRedeliveryBackOffMultiplier, getRedeliveryUseExponentialBackOff, getServerUrl, getTopicPrefetch, getTrustStore, getTrustStorePassword, getUseInboundSession, getUserName, getUseSessionArgs, isUseInboundSessionEnabled, isUseSessionArgs, makeConnection, makeConnection, notEqual, setAllPrefetchValues, setClientid, setDurableTopicPrefetch, setInfo, setInitialRedeliveryDelay, setKeyStore, setKeyStoreKeyPassword, setKeyStorePassword, setMaximumRedeliveries, setMaximumRedeliveryDelay, setOptimizeDurableTopicPrefetch, setPassword, setQueueBrowserPrefetch, setQueuePrefetch, setRedeliveryBackOffMultiplier, setRedeliveryUseExponentialBackOff, setServerUrl, setTopicPrefetch, setTrustStore, setTrustStorePassword, setUseInboundSession, setUserName, setUseSessionArgs

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ActiveMQManagedConnectionFactory

public ActiveMQManagedConnectionFactory()

Method Details

setResourceAdapter

public void setResourceAdapter(jakarta.resource.spi.ResourceAdapter adapter)
                        throws jakarta.resource.ResourceException

Specified by:

setResourceAdapter in interface jakarta.resource.spi.ResourceAdapterAssociation

Throws:

jakarta.resource.ResourceException

See Also:

• javax.resource.spi.ResourceAdapterAssociation#setResourceAdapter(javax.resource.spi.ResourceAdapter)

getResourceAdapter

public jakarta.resource.spi.ResourceAdapter getResourceAdapter()

Specified by:

getResourceAdapter in interface jakarta.resource.spi.ResourceAdapterAssociation

See Also:

• javax.resource.spi.ResourceAdapterAssociation#getResourceAdapter()

equals

public boolean equals(Object object)

Specified by:

equals in interface jakarta.resource.spi.ManagedConnectionFactory

Overrides:

equals in class Object

See Also:

• Object.equals(java.lang.Object)

hashCode

public int hashCode()

Specified by:

hashCode in interface jakarta.resource.spi.ManagedConnectionFactory

Overrides:

hashCode in class Object

See Also:

• Object.hashCode()

createConnectionFactory

public Object createConnectionFactory(jakarta.resource.spi.ConnectionManager manager)
                               throws jakarta.resource.ResourceException

Specified by:

createConnectionFactory in interface jakarta.resource.spi.ManagedConnectionFactory

Throws:

jakarta.resource.ResourceException

See Also:

• javax.resource.spi.ManagedConnectionFactory#createConnectionFactory(javax.resource.spi.ConnectionManager)

createConnectionFactory

public Object createConnectionFactory()
                               throws jakarta.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 jakarta.resource.spi.ManagedConnectionFactory

Throws:

jakarta.resource.ResourceException

See Also:

• javax.resource.spi.ManagedConnectionFactory#createConnectionFactory()

createManagedConnection

public jakarta.resource.spi.ManagedConnection createManagedConnection(Subject subject,
 jakarta.resource.spi.ConnectionRequestInfo connectionRequestInfo)
                                                               throws jakarta.resource.ResourceException

Specified by:

createManagedConnection in interface jakarta.resource.spi.ManagedConnectionFactory

Throws:

jakarta.resource.ResourceException

See Also:

• javax.resource.spi.ManagedConnectionFactory#createManagedConnection(javax.security.auth.Subject, javax.resource.spi.ConnectionRequestInfo)

matchManagedConnections

public jakarta.resource.spi.ManagedConnection matchManagedConnections(Set connections,
 Subject subject,
 jakarta.resource.spi.ConnectionRequestInfo connectionRequestInfo)
                                                               throws jakarta.resource.ResourceException

Specified by:

matchManagedConnections in interface jakarta.resource.spi.ManagedConnectionFactory

Throws:

jakarta.resource.ResourceException

See Also:

• javax.resource.spi.ManagedConnectionFactory#matchManagedConnections(java.util.Set, javax.security.auth.Subject, javax.resource.spi.ConnectionRequestInfo)

setLogWriter

public void setLogWriter(PrintWriter aLogWriter)
                  throws jakarta.resource.ResourceException

Specified by:

setLogWriter in interface jakarta.resource.spi.ManagedConnectionFactory

Throws:

jakarta.resource.ResourceException

See Also:

• javax.resource.spi.ManagedConnectionFactory#setLogWriter(java.io.PrintWriter)

getLogWriter

public PrintWriter getLogWriter()
                         throws jakarta.resource.ResourceException

Specified by:

getLogWriter in interface jakarta.resource.spi.ManagedConnectionFactory

Throws:

jakarta.resource.ResourceException

See Also:

• javax.resource.spi.ManagedConnectionFactory#getLogWriter()