public class QpidRAManagedConnectionFactory extends Object implements javax.resource.spi.ManagedConnectionFactory, javax.resource.spi.ResourceAdapterAssociation
Constructor and Description |
---|
QpidRAManagedConnectionFactory()
Constructor
|
Modifier and Type | Method and Description |
---|---|
Object |
createConnectionFactory()
Creates a Connection Factory instance
|
Object |
createConnectionFactory(javax.resource.spi.ConnectionManager cxManager)
Creates a Connection Factory instance
|
javax.resource.spi.ManagedConnection |
createManagedConnection(Subject subject,
javax.resource.spi.ConnectionRequestInfo cxRequestInfo)
Creates a new physical connection to the underlying EIS resource manager.
|
boolean |
equals(Object obj)
Indicates whether some other object is "equal to" this one.
|
protected AMQConnectionFactory |
getCleanAMQConnectionFactory()
Get a clean connection factory
|
String |
getClientId() |
String |
getConnectionURL() |
protected AMQConnectionFactory |
getDefaultAMQConnectionFactory()
Get the default connection factory
|
String |
getHost() |
PrintWriter |
getLogWriter()
Get the log writer -- NOT SUPPORTED
|
javax.jms.ConnectionMetaData |
getMetaData()
Get the connection metadata
|
String |
getPassword() |
String |
getPath() |
Integer |
getPort() |
protected QpidRAMCFProperties |
getProperties()
Get the managed connection factory properties
|
javax.resource.spi.ResourceAdapter |
getResourceAdapter()
Get the resource adapter
|
String |
getSessionDefaultType()
Get the default session type
|
Boolean |
getUseLocalTx() |
String |
getUserName() |
Integer |
getUseTryLock()
Get the useTryLock.
|
int |
hashCode()
Return the hash code for the object
|
javax.resource.spi.ManagedConnection |
matchManagedConnections(Set connectionSet,
Subject subject,
javax.resource.spi.ConnectionRequestInfo cxRequestInfo)
Returns a matched connection from the candidate set of connections.
|
void |
setClientId(String clientID) |
void |
setConnectionURL(String connectionURL) |
void |
setHost(String host) |
void |
setLogWriter(PrintWriter out)
Set the log writer -- NOT SUPPORTED
|
void |
setPassword(String defaultPassword) |
void |
setPath(String path) |
void |
setPort(Integer port) |
void |
setResourceAdapter(javax.resource.spi.ResourceAdapter ra)
Set the resource adapter
|
void |
setSessionDefaultType(String type)
Set the default session type
|
void |
setUseLocalTx(Boolean localTx) |
void |
setUserName(String defaultUsername) |
void |
setUseTryLock(Integer useTryLock)
Set the useTryLock.
|
public QpidRAManagedConnectionFactory()
public Object createConnectionFactory() throws javax.resource.ResourceException
createConnectionFactory
in interface javax.resource.spi.ManagedConnectionFactory
javax.resource.ResourceException
- Thrown if a connection factory cant be createdpublic Object createConnectionFactory(javax.resource.spi.ConnectionManager cxManager) throws javax.resource.ResourceException
createConnectionFactory
in interface javax.resource.spi.ManagedConnectionFactory
cxManager
- The connection managerjavax.resource.ResourceException
- Thrown if a connection factory cant be createdpublic javax.resource.spi.ManagedConnection createManagedConnection(Subject subject, javax.resource.spi.ConnectionRequestInfo cxRequestInfo) throws javax.resource.ResourceException
createManagedConnection
in interface javax.resource.spi.ManagedConnectionFactory
subject
- Caller's security informationcxRequestInfo
- Additional resource adapter specific connection request informationjavax.resource.ResourceException
- Thrown if a managed connection cant be createdpublic javax.resource.spi.ManagedConnection matchManagedConnections(Set connectionSet, Subject subject, javax.resource.spi.ConnectionRequestInfo cxRequestInfo) throws javax.resource.ResourceException
matchManagedConnections
in interface javax.resource.spi.ManagedConnectionFactory
connectionSet
- The candidate connection setsubject
- Caller's security informationcxRequestInfo
- Additional resource adapter specific connection request informationjavax.resource.ResourceException
- Thrown if no managed connection can be foundpublic void setLogWriter(PrintWriter out) throws javax.resource.ResourceException
setLogWriter
in interface javax.resource.spi.ManagedConnectionFactory
out
- The writerjavax.resource.ResourceException
- Thrown if the writer cant be setpublic PrintWriter getLogWriter() throws javax.resource.ResourceException
getLogWriter
in interface javax.resource.spi.ManagedConnectionFactory
javax.resource.ResourceException
- Thrown if the writer cant be retrievedpublic javax.resource.spi.ResourceAdapter getResourceAdapter()
getResourceAdapter
in interface javax.resource.spi.ResourceAdapterAssociation
public void setResourceAdapter(javax.resource.spi.ResourceAdapter ra) throws javax.resource.ResourceException
setResourceAdapter
in interface javax.resource.spi.ResourceAdapterAssociation
ra
- The resource adapterjavax.resource.ResourceException
- Thrown if incorrect resource adapterpublic boolean equals(Object obj)
public int hashCode()
public String getSessionDefaultType()
public void setSessionDefaultType(String type)
type
- either javax.jms.Topic or javax.jms.Queuepublic String getClientId()
public void setClientId(String clientID)
public String getConnectionURL()
public void setConnectionURL(String connectionURL)
public String getPassword()
public void setPassword(String defaultPassword)
public String getUserName()
public void setUserName(String defaultUsername)
public String getHost()
public void setHost(String host)
public Integer getPort()
public void setPort(Integer port)
public String getPath()
public void setPath(String path)
public Integer getUseTryLock()
public void setUseTryLock(Integer useTryLock)
useTryLock
- the useTryLock.public javax.jms.ConnectionMetaData getMetaData()
protected AMQConnectionFactory getDefaultAMQConnectionFactory() throws javax.resource.ResourceException
javax.resource.ResourceException
protected AMQConnectionFactory getCleanAMQConnectionFactory() throws javax.resource.ResourceException
javax.resource.ResourceException
protected QpidRAMCFProperties getProperties()
public Boolean getUseLocalTx()
public void setUseLocalTx(Boolean localTx)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.