public abstract class AbstractConnectionManager extends java.lang.Object implements ConnectionManager
Modifier and Type | Field and Description |
---|---|
protected java.lang.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 java.lang.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
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)
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()
isTransactional
in interface ConnectionListenerFactory
public abstract TransactionIntegration getTransactionIntegration()
getTransactionIntegration
in interface ConnectionListenerFactory
Copyright © 2013 IronJacamar (http://www.ironjacamar.org)