public abstract class AbstractConnectionManager extends java.lang.Object implements ConnectionManager
Modifier and Type | Field and Description |
---|---|
protected boolean |
enlistment
Enlistment
|
protected boolean |
trace
Log trace
|
Modifier | Constructor and Description |
---|---|
protected |
AbstractConnectionManager()
Creates a new instance of connection manager.
|
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
allocateConnection(javax.resource.spi.ManagedConnectionFactory mcf,
javax.resource.spi.ConnectionRequestInfo cri) |
void |
associateConnection(java.lang.Object connection,
javax.resource.spi.ManagedConnectionFactory mcf,
javax.resource.spi.ConnectionRequestInfo cri) |
javax.resource.spi.ManagedConnection |
associateManagedConnection(java.lang.Object connection,
javax.resource.spi.ManagedConnectionFactory mcf,
javax.resource.spi.ConnectionRequestInfo cri)
Associate a managed connection to a logical connection
|
void |
disconnect(java.util.Collection<ConnectionRecord> conRecords,
java.util.Set<java.lang.String> unsharableResources)
Notification to disconnect connections
|
protected void |
disconnectManagedConnection(ConnectionListener cl)
Invoked when a managed connection is no longer associated
|
boolean |
dissociateManagedConnection(java.lang.Object connection,
javax.resource.spi.ManagedConnection mc,
javax.resource.spi.ManagedConnectionFactory mcf)
Dissociate a managed connection from a logical connection.
|
int |
getAllocationRetry()
Get the number of allocation retries
|
long |
getAllocationRetryWaitMillis()
Get the wait time between each allocation retry
|
CachedConnectionManager |
getCachedConnectionManager()
Gets cached connection manager.
|
org.jboss.jca.common.api.metadata.common.FlushStrategy |
getFlushStrategy()
Get the flush strategy
|
java.lang.String |
getJndiName()
Gets jndi name.
|
protected abstract CoreLogger |
getLogger()
Get the logger.
|
ConnectionListener |
getManagedConnection(javax.security.auth.Subject subject,
javax.resource.spi.ConnectionRequestInfo cri)
Public for use in testing pooling functionality by itself.
|
protected ConnectionListener |
getManagedConnection(javax.transaction.Transaction transaction,
javax.security.auth.Subject subject,
javax.resource.spi.ConnectionRequestInfo cri)
Get the managed connection from the pool.
|
javax.resource.spi.ManagedConnectionFactory |
getManagedConnectionFactory()
Gets managed connection factory.
|
Pool |
getPool()
Get the pool.
|
java.lang.String |
getSecurityDomain()
Get the security domain.
|
org.jboss.security.SubjectFactory |
getSubjectFactory()
Get the subject factory
|
abstract TransactionIntegration |
getTransactionIntegration()
Get the transaction integration.
|
void |
inactiveConnectionClosed(java.lang.Object connection,
javax.resource.spi.ManagedConnectionFactory mcf) |
boolean |
isEnlistment()
Is enlistment
|
boolean |
isSharable()
Is sharable
|
abstract boolean |
isTransactional()
Determine whether there connection is a transactional.
|
void |
lazyEnlist(javax.resource.spi.ManagedConnection mc) |
protected void |
managedConnectionDisconnected(ConnectionListener cl)
For polymorphism.
|
protected void |
managedConnectionReconnected(ConnectionListener cl)
For polymorphism.
|
void |
reconnect(java.util.Collection<ConnectionRecord> conns,
java.util.Set<java.lang.String> unsharableResources)
Notification to reconnect connections
|
protected void |
reconnectManagedConnection(ConnectionListener cl)
Invoked to reassociate a managed connection.
|
void |
returnManagedConnection(ConnectionListener bcl,
boolean kill)
Kill given connection listener wrapped connection instance.
|
void |
setAllocationRetry(int number)
Set the number of allocation retries
|
void |
setAllocationRetryWaitMillis(long millis)
Set the wait time between each allocation retry
|
void |
setCachedConnectionManager(CachedConnectionManager cachedConnectionManager)
Sets cached connection manager.
|
void |
setEnlistment(boolean v)
Set the enlistment flag
|
void |
setFlushStrategy(org.jboss.jca.common.api.metadata.common.FlushStrategy v)
Set the flush strategy
|
void |
setJndiName(java.lang.String jndiName)
Sets jndi name.
|
void |
setPool(Pool pool)
Set the pool.
|
void |
setSecurityDomain(java.lang.String securityDomain)
Sets security domain
|
void |
setSharable(boolean v)
Set the sharable flag
|
void |
setSubjectFactory(org.jboss.security.SubjectFactory subjectFactory)
Sets subject factory.
|
void |
shutdown()
Shutdown
|
abstract void |
transactionStarted(java.util.Collection<ConnectionRecord> conns)
Notification of transaction started
|
void |
unregisterAssociation(ConnectionListener cl,
java.lang.Object c)
Unregister association.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createConnectionListener
protected boolean trace
protected boolean enlistment
protected AbstractConnectionManager()
protected abstract CoreLogger getLogger()
public void setPool(Pool pool)
pool
- the poolpublic Pool getPool()
public void setCachedConnectionManager(CachedConnectionManager cachedConnectionManager)
cachedConnectionManager
- cached connection managerpublic CachedConnectionManager getCachedConnectionManager()
public void shutdown()
public java.lang.String getJndiName()
public void setJndiName(java.lang.String jndiName)
jndiName
- jndi namepublic boolean isSharable()
public void setSharable(boolean v)
v
- The valuepublic boolean isEnlistment()
public void setEnlistment(boolean v)
v
- The valuepublic java.lang.String getSecurityDomain()
public void setSecurityDomain(java.lang.String securityDomain)
securityDomain
- security domainpublic org.jboss.security.SubjectFactory getSubjectFactory()
public void setSubjectFactory(org.jboss.security.SubjectFactory subjectFactory)
subjectFactory
- subject factorypublic org.jboss.jca.common.api.metadata.common.FlushStrategy getFlushStrategy()
public void setFlushStrategy(org.jboss.jca.common.api.metadata.common.FlushStrategy v)
v
- The valuepublic javax.resource.spi.ManagedConnectionFactory getManagedConnectionFactory()
public void setAllocationRetry(int number)
number
- retry numberpublic int getAllocationRetry()
public void setAllocationRetryWaitMillis(long millis)
millis
- wait in mspublic long getAllocationRetryWaitMillis()
public ConnectionListener getManagedConnection(javax.security.auth.Subject subject, javax.resource.spi.ConnectionRequestInfo cri) throws javax.resource.ResourceException
subject
- a Subject
valuecri
- a ConnectionRequestInfo
valueManagedConnection
valuejavax.resource.ResourceException
- if an error occursprotected ConnectionListener getManagedConnection(javax.transaction.Transaction transaction, javax.security.auth.Subject subject, javax.resource.spi.ConnectionRequestInfo cri) throws javax.resource.ResourceException
transaction
- the transaction for track by transactionsubject
- the subjectcri
- the ConnectionRequestInfojavax.resource.ResourceException
- if an error occurspublic void returnManagedConnection(ConnectionListener bcl, boolean kill)
bcl
- connection listener that wraps connectionkill
- kill connection or notpublic java.lang.Object allocateConnection(javax.resource.spi.ManagedConnectionFactory mcf, javax.resource.spi.ConnectionRequestInfo cri) throws javax.resource.ResourceException
allocateConnection
in interface javax.resource.spi.ConnectionManager
javax.resource.ResourceException
public void associateConnection(java.lang.Object connection, javax.resource.spi.ManagedConnectionFactory mcf, javax.resource.spi.ConnectionRequestInfo cri) throws javax.resource.ResourceException
associateConnection
in interface javax.resource.spi.LazyAssociatableConnectionManager
javax.resource.ResourceException
public javax.resource.spi.ManagedConnection associateManagedConnection(java.lang.Object connection, javax.resource.spi.ManagedConnectionFactory mcf, javax.resource.spi.ConnectionRequestInfo cri) throws javax.resource.ResourceException
connection
- The connectionmcf
- The managed connection factorycri
- The connection request informationjavax.resource.ResourceException
- Thrown if an error occurspublic boolean dissociateManagedConnection(java.lang.Object connection, javax.resource.spi.ManagedConnection mc, javax.resource.spi.ManagedConnectionFactory mcf) throws javax.resource.ResourceException
cleanup
method
will be calledconnection
- The connectionmc
- The managed connectionmcf
- The managed connection factoryjavax.resource.ResourceException
- Thrown if an error occurspublic void inactiveConnectionClosed(java.lang.Object connection, javax.resource.spi.ManagedConnectionFactory mcf)
inactiveConnectionClosed
in interface javax.resource.spi.LazyAssociatableConnectionManager
public void disconnect(java.util.Collection<ConnectionRecord> conRecords, java.util.Set<java.lang.String> unsharableResources) throws javax.resource.ResourceException
conRecords
- the connectionsunsharableResources
- the unshareable resourcesjavax.resource.ResourceException
- for any errorpublic void reconnect(java.util.Collection<ConnectionRecord> conns, java.util.Set<java.lang.String> unsharableResources) throws javax.resource.ResourceException
conns
- the connectionsunsharableResources
- unshareable resourcesjavax.resource.ResourceException
- for any errorpublic void unregisterAssociation(ConnectionListener cl, java.lang.Object c)
cl
- connection listenerc
- connectionpublic void lazyEnlist(javax.resource.spi.ManagedConnection mc) throws javax.resource.ResourceException
lazyEnlist
in interface javax.resource.spi.LazyEnlistableConnectionManager
javax.resource.ResourceException
protected void reconnectManagedConnection(ConnectionListener cl) throws javax.resource.ResourceException
cl
- the managed connectionjavax.resource.ResourceException
- for exceptionprotected void disconnectManagedConnection(ConnectionListener cl)
cl
- the managed connectionprotected void managedConnectionReconnected(ConnectionListener cl) throws javax.resource.ResourceException
Do not invoke directly, use reconnectManagedConnection which does the relevent exception handling
cl
- connection listenerjavax.resource.ResourceException
- for exceptionprotected void managedConnectionDisconnected(ConnectionListener cl) throws javax.resource.ResourceException
Do not invoke directly, use disconnectManagedConnection which does the relevent exception handling
cl
- connection listenerjavax.resource.ResourceException
- for exceptionpublic abstract void transactionStarted(java.util.Collection<ConnectionRecord> conns) throws javax.transaction.SystemException
conns
- the connectionsjavax.transaction.SystemException
- for any errorpublic abstract boolean isTransactional()
public abstract TransactionIntegration getTransactionIntegration()
Copyright © 2013 IronJacamar (http://www.ironjacamar.org)