org.apache.activemq.ra
Class ActiveMQManagedConnectionFactory
java.lang.Object
org.apache.activemq.ra.ActiveMQManagedConnectionFactory
- All Implemented Interfaces:
- Serializable, javax.resource.spi.ManagedConnectionFactory, javax.resource.spi.ResourceAdapterAssociation
public class ActiveMQManagedConnectionFactory
- extends 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
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(Object object)
- Specified by:
equals
in interface javax.resource.spi.ManagedConnectionFactory
- Overrides:
equals
in class Object
hashCode
public int hashCode()
- Specified by:
hashCode
in interface javax.resource.spi.ManagedConnectionFactory
- Overrides:
hashCode
in class Object
getResourceAdapter
public javax.resource.spi.ResourceAdapter getResourceAdapter()
- Specified by:
getResourceAdapter
in interface javax.resource.spi.ResourceAdapterAssociation
createConnectionFactory
public 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 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(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(Set connections,
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(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 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 String getClientid()
getPassword
public String getPassword()
getUserName
public String getUserName()
setClientid
public void setClientid(String clientid)
setPassword
public void setPassword(String password)
setUserName
public void setUserName(String userid)
getUseInboundSession
public Boolean getUseInboundSession()
setUseInboundSession
public void setUseInboundSession(Boolean useInboundSession)
isUseInboundSessionEnabled
public boolean isUseInboundSessionEnabled()
getInitialRedeliveryDelay
public Long getInitialRedeliveryDelay()
getMaximumRedeliveries
public Integer getMaximumRedeliveries()
getRedeliveryBackOffMultiplier
public Short getRedeliveryBackOffMultiplier()
getRedeliveryUseExponentialBackOff
public Boolean getRedeliveryUseExponentialBackOff()
setInitialRedeliveryDelay
public void setInitialRedeliveryDelay(Long value)
setMaximumRedeliveries
public void setMaximumRedeliveries(Integer value)
setRedeliveryBackOffMultiplier
public void setRedeliveryBackOffMultiplier(Short value)
setRedeliveryUseExponentialBackOff
public void setRedeliveryUseExponentialBackOff(Boolean value)
getDurableTopicPrefetch
public Integer getDurableTopicPrefetch()
getInputStreamPrefetch
public Integer getInputStreamPrefetch()
getQueueBrowserPrefetch
public Integer getQueueBrowserPrefetch()
getQueuePrefetch
public Integer getQueuePrefetch()
getTopicPrefetch
public Integer getTopicPrefetch()
setAllPrefetchValues
public void setAllPrefetchValues(Integer i)
setDurableTopicPrefetch
public void setDurableTopicPrefetch(Integer durableTopicPrefetch)
setInputStreamPrefetch
public void setInputStreamPrefetch(Integer inputStreamPrefetch)
setQueueBrowserPrefetch
public void setQueueBrowserPrefetch(Integer queueBrowserPrefetch)
setQueuePrefetch
public void setQueuePrefetch(Integer queuePrefetch)
setTopicPrefetch
public void setTopicPrefetch(Integer topicPrefetch)
Copyright © 2011 Apache Software Foundation. All Rights Reserved.