org.apache.activemq.ra
Class ActiveMQManagedConnectionFactory
java.lang.Object
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
Methods inherited from class java.lang.Object |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait |
ActiveMQManagedConnectionFactory
public ActiveMQManagedConnectionFactory()
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 © 2011 Apache Software Foundation. All Rights Reserved.