public class ManagedConnectionFactoryImpl extends ManagedConnectionFactoryConfig implements jakarta.resource.spi.ManagedConnectionFactory, jakarta.resource.spi.ResourceAdapterAssociation, jakarta.resource.spi.ValidatingManagedConnectionFactory, Serializable
ManagedConnectionFactoryImpl
instance manages
outbound connectivity to a given JORAM server.Modifier and Type | Field and Description |
---|---|
static Logger |
logger |
protected PrintWriter |
out
Out stream for error logging and tracing.
|
(package private) JoramResourceAdapter |
ra
Resource adapter central authority.
|
private static long |
serialVersionUID
Define serialVersionUID for interoperability.
|
asyncSend, MODE_PTP, MODE_PUBSUB, MODE_UNIFIED
Constructor and Description |
---|
ManagedConnectionFactoryImpl()
Constructs a
ManagedConnectionFactoryImpl instance. |
Modifier and Type | Method and Description |
---|---|
Object |
createConnectionFactory()
Method called in the non managed case for creating an
OutboundConnectionFactory instance. |
Object |
createConnectionFactory(jakarta.resource.spi.ConnectionManager cxManager)
Method called by an application server (managed case) for creating an
OutboundConnectionFactory instance. |
protected jakarta.jms.XAConnectionFactory |
createFactory(jakarta.resource.spi.ConnectionRequestInfo cxRequest) |
jakarta.resource.spi.ManagedConnection |
createManagedConnection(Subject subject,
jakarta.resource.spi.ConnectionRequestInfo cxRequest)
Creates a new physical connection to the underlying JORAM server,
and returns a
ManagedConnectionImpl instance for a
managed environment. |
protected jakarta.jms.XAConnection |
createXAConnection(jakarta.jms.XAConnectionFactory factory,
String userName,
String password) |
boolean |
equals(Object o)
Compares managed factories according to their configuration.
|
Set |
getInvalidConnections(Set connectionSet)
From a set of managed connections, returns the set of invalid ones.
|
PrintWriter |
getLogWriter()
Gets the log writer of this
ManagedConnectionFactoryImpl
instance. |
jakarta.resource.spi.ResourceAdapter |
getResourceAdapter()
Returns the resource adapter central authority instance.
|
int |
hashCode()
Returns a code depending on the managed factory configuration.
|
jakarta.resource.spi.ManagedConnection |
matchManagedConnections(Set connectionSet,
Subject subject,
jakarta.resource.spi.ConnectionRequestInfo cxRequest)
Finds a matching connection from the candidate set of connections and
returns a
ManagedConnectionImpl instance. |
void |
setLogWriter(PrintWriter out)
Sets the log writer for this
ManagedConnectionFactoryImpl
instance. |
void |
setResourceAdapter(jakarta.resource.spi.ResourceAdapter ra)
Sets the resource adapter central authority.
|
getAsyncSend, getCnxPendingTimer, getConnectingTimer, getHostName, getIdentityClass, getMode, getMultiThreadSync, getMultiThreadSyncDelay, getName, getOutLocalAddress, getOutLocalPort, getPassword, getServerPort, getTxPendingTimer, getUserName, isAsyncSend, isCollocated, isMultiThreadSync, setAsyncSend, setCnxPendingTimer, setCollocated, setConnectingTimer, setHostName, setIdentityClass, setInInterceptors, setManagedConnectionFactoryConfig, setMode, setMultiThreadSync, setMultiThreadSyncDelay, setName, setOutInterceptors, setOutLocalAddress, setOutLocalPort, setParameters, setPassword, setServerPort, setTxPendingTimer, setUserName
private static final long serialVersionUID
public static Logger logger
protected transient PrintWriter out
transient JoramResourceAdapter ra
public ManagedConnectionFactoryImpl()
ManagedConnectionFactoryImpl
instance.public Object createConnectionFactory(jakarta.resource.spi.ConnectionManager cxManager) throws jakarta.resource.ResourceException
OutboundConnectionFactory
instance.createConnectionFactory
in interface jakarta.resource.spi.ManagedConnectionFactory
cxManager
- Application server's connections pooling manager.jakarta.resource.ResourceException
- Never thrown.public Object createConnectionFactory() throws jakarta.resource.ResourceException
OutboundConnectionFactory
instance.createConnectionFactory
in interface jakarta.resource.spi.ManagedConnectionFactory
jakarta.resource.ResourceException
- Never thrown.protected jakarta.jms.XAConnectionFactory createFactory(jakarta.resource.spi.ConnectionRequestInfo cxRequest) throws jakarta.resource.ResourceException
jakarta.resource.ResourceException
protected jakarta.jms.XAConnection createXAConnection(jakarta.jms.XAConnectionFactory factory, String userName, String password) throws jakarta.resource.ResourceException
jakarta.resource.ResourceException
public final jakarta.resource.spi.ManagedConnection createManagedConnection(Subject subject, jakarta.resource.spi.ConnectionRequestInfo cxRequest) throws jakarta.resource.ResourceException
ManagedConnectionImpl
instance for a
managed environment.createManagedConnection
in interface jakarta.resource.spi.ManagedConnectionFactory
subject
- Security data, not taken into account.cxRequest
- User identification data, may be null
.jakarta.resource.spi.CommException
- If the JORAM server is not reachable.jakarta.resource.spi.SecurityException
- If the connecting is not allowed.jakarta.jms.IllegalStateException
- If the central Joram adapter state is
invalid.jakarta.resource.ResourceException
- If the provided user info is invalid,
or if connecting fails for any other
reason.public final jakarta.resource.spi.ManagedConnection matchManagedConnections(Set connectionSet, Subject subject, jakarta.resource.spi.ConnectionRequestInfo cxRequest) throws jakarta.resource.ResourceException
ManagedConnectionImpl
instance.matchManagedConnections
in interface jakarta.resource.spi.ManagedConnectionFactory
connectionSet
- Set of connections to test.subject
- Security data, not taken into account.cxRequest
- User identification data, may be null
.jakarta.resource.ResourceException
- If the provided connection request info is
invalid.public void setLogWriter(PrintWriter out) throws jakarta.resource.ResourceException
ManagedConnectionFactoryImpl
instance.setLogWriter
in interface jakarta.resource.spi.ManagedConnectionFactory
jakarta.resource.ResourceException
public PrintWriter getLogWriter() throws jakarta.resource.ResourceException
ManagedConnectionFactoryImpl
instance.getLogWriter
in interface jakarta.resource.spi.ManagedConnectionFactory
jakarta.resource.ResourceException
public int hashCode()
public boolean equals(Object o)
public jakarta.resource.spi.ResourceAdapter getResourceAdapter()
getResourceAdapter
in interface jakarta.resource.spi.ResourceAdapterAssociation
public void setResourceAdapter(jakarta.resource.spi.ResourceAdapter ra) throws jakarta.resource.ResourceException
setResourceAdapter
in interface jakarta.resource.spi.ResourceAdapterAssociation
jakarta.resource.ResourceException
- If the adapter could not be set.public Set getInvalidConnections(Set connectionSet) throws jakarta.resource.ResourceException
getInvalidConnections
in interface jakarta.resource.spi.ValidatingManagedConnectionFactory
jakarta.resource.ResourceException
Copyright © 2022 ScalAgent D.T.. All rights reserved.