public abstract class AbstractConnectionListener extends java.lang.Object implements ConnectionListener, ConnectableResourceListener
ConnectionListener
interface
contract.Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.CopyOnWriteArraySet<java.lang.Object> |
connectionHandles
Connection handles
|
protected java.util.Map<java.lang.Object,java.lang.Exception> |
connectionTraces
Connection traces
|
protected java.lang.Boolean |
tracking
Tracking
|
Modifier | Constructor and Description |
---|---|
protected |
AbstractConnectionListener(ConnectionManager cm,
javax.resource.spi.ManagedConnection managedConnection,
Pool pool,
ManagedConnectionPool mcp,
org.jboss.jca.common.api.metadata.common.FlushStrategy flushStrategy,
java.lang.Boolean tracking)
Creates a new instance of the listener that is responsible for
tracking the owned connection instance.
|
Modifier and Type | Method and Description |
---|---|
int |
compareTo(java.lang.Object o)
Compare
|
void |
connectionClosed(javax.resource.spi.ConnectionEvent event) |
void |
connectionErrorOccurred(javax.resource.spi.ConnectionEvent event) |
boolean |
controls(javax.resource.spi.ManagedConnection mc,
java.lang.Object connection)
Controls the managed connection / connection pair
|
boolean |
delist()
Delist the managed connection
|
void |
dissociate()
Dissociate the connection listener
|
void |
enlist()
Enlist the managed connection
|
protected CachedConnectionManager |
getCachedConnectionManager()
Gets cached connection manager
|
protected ConnectionManager |
getConnectionManager()
Gets connection manager.
|
java.lang.Exception |
getException()
Get exception
|
long |
getLastCheckedOutTime()
Retrieve the last time this connection was obtained from the pool
|
long |
getLastReturnedTime()
Retrieve the last time this connection was returned to the pool
|
long |
getLastValidatedTime()
Retrieve the last time this connection was validated.
|
protected abstract CoreLogger |
getLogger()
Get the logger
|
javax.resource.spi.ManagedConnection |
getManagedConnection()
Retrieve the managed connection for this listener.
|
ManagedConnectionPool |
getManagedConnectionPool()
Get the managed connection pool
|
int |
getNumberOfConnections()
Get number of connection handles
|
Pool |
getPool()
Retrieve the pool for this listener.
|
ConnectionState |
getState()
Retrieve the state of this connection.
|
void |
handleClosed(java.lang.Object h)
Handle closed
|
void |
handleCreated(java.lang.Object h)
Handle created
|
boolean |
isEnlisted()
Is enlisted
|
boolean |
isManagedConnectionFree()
Is the managed connection free?
|
boolean |
isTimedOut(long timeout)
Has the connection timed out?
|
boolean |
isTrackByTx()
Get whether the listener is track by transaction
|
void |
localTransactionCommitted(javax.resource.spi.ConnectionEvent event) |
void |
localTransactionRolledback(javax.resource.spi.ConnectionEvent event) |
void |
localTransactionStarted(javax.resource.spi.ConnectionEvent event) |
void |
registerConnection(java.lang.Object handle)
Register a new connection
|
void |
setLastCheckedOutTime(long v)
Set the last time this connection was obtained from the pool
|
void |
setLastValidatedTime(long lastValidated)
Set the last time, in milliseconds, that this connection was validated.
|
void |
setState(ConnectionState newState)
Set the state of this connection.
|
void |
setTrackByTx(boolean trackByTx)
Set whether the listener is track by transaction
|
boolean |
supportsLazyAssociation()
Supports lazy association
|
boolean |
supportsLazyEnlistment()
Supports lazy enlistment
|
void |
tidyup()
Tidyup
|
void |
toPool()
Mark the connection as in pool
|
java.lang.String |
toString() |
protected void |
toString(java.lang.StringBuffer buffer)
Add specific properties.
|
void |
unregisterConnection(java.lang.Object handle)
Unregister a connection
|
void |
unregisterConnections()
Unregister connections.
|
protected java.util.concurrent.CopyOnWriteArraySet<java.lang.Object> connectionHandles
protected java.util.Map<java.lang.Object,java.lang.Exception> connectionTraces
protected java.lang.Boolean tracking
protected AbstractConnectionListener(ConnectionManager cm, javax.resource.spi.ManagedConnection managedConnection, Pool pool, ManagedConnectionPool mcp, org.jboss.jca.common.api.metadata.common.FlushStrategy flushStrategy, java.lang.Boolean tracking)
cm
- connection managermanagedConnection
- managed connectionpool
- poolmcp
- managed connection poolflushStrategy
- flushStrategytracking
- trackingprotected CachedConnectionManager getCachedConnectionManager()
protected ConnectionManager getConnectionManager()
protected abstract CoreLogger getLogger()
public int getNumberOfConnections()
public boolean isEnlisted()
public boolean delist() throws javax.resource.ResourceException
True
if the listener was delisted succesfully, otherwise false
javax.resource.ResourceException
- if exception occurspublic void enlist() throws javax.transaction.SystemException
javax.transaction.SystemException
- for errorspublic ManagedConnectionPool getManagedConnectionPool()
public long getLastValidatedTime()
public long getLastReturnedTime()
public long getLastCheckedOutTime()
public void setLastCheckedOutTime(long v)
v
- The valuepublic javax.resource.spi.ManagedConnection getManagedConnection()
getManagedConnection
in interface ConnectionListener
public Pool getPool()
public ConnectionState getState()
public boolean isManagedConnectionFree()
public boolean isTimedOut(long timeout)
timeout
- the timeoutpublic boolean isTrackByTx()
public void registerConnection(java.lang.Object handle)
handle
- the connection handlepublic void setLastValidatedTime(long lastValidated)
lastValidated
- the last time the connection was validated in
milliseconds.public void setState(ConnectionState newState)
newState
- new statepublic void setTrackByTx(boolean trackByTx)
trackByTx
- true for track by transaction, false otherwisepublic void tidyup() throws javax.resource.ResourceException
Invoked just before returning the connection to the pool when the connection is not being destroyed.
javax.resource.ResourceException
- for any errorpublic void unregisterConnection(java.lang.Object handle)
handle
- the connection handlepublic void unregisterConnections()
public void toPool()
public void connectionClosed(javax.resource.spi.ConnectionEvent event)
connectionClosed
in interface javax.resource.spi.ConnectionEventListener
public void connectionErrorOccurred(javax.resource.spi.ConnectionEvent event)
connectionErrorOccurred
in interface javax.resource.spi.ConnectionEventListener
public java.lang.Exception getException()
null
public boolean controls(javax.resource.spi.ManagedConnection mc, java.lang.Object connection)
mc
- The managed connectionconnection
- The connection; optionalpublic void dissociate() throws javax.resource.ResourceException
javax.resource.ResourceException
- if exception occurspublic boolean supportsLazyAssociation()
True
if supported, otherwise false
public boolean supportsLazyEnlistment()
True
if supported, otherwise false
public void localTransactionCommitted(javax.resource.spi.ConnectionEvent event)
localTransactionCommitted
in interface javax.resource.spi.ConnectionEventListener
public void localTransactionRolledback(javax.resource.spi.ConnectionEvent event)
localTransactionRolledback
in interface javax.resource.spi.ConnectionEventListener
public void localTransactionStarted(javax.resource.spi.ConnectionEvent event)
localTransactionStarted
in interface javax.resource.spi.ConnectionEventListener
public void handleCreated(java.lang.Object h)
handleCreated
in interface ConnectableResourceListener
h
- The handlepublic void handleClosed(java.lang.Object h)
handleClosed
in interface ConnectableResourceListener
h
- The handlepublic int compareTo(java.lang.Object o)
compareTo
in interface java.lang.Comparable
o
- The other objectpublic java.lang.String toString()
toString
in class java.lang.Object
protected void toString(java.lang.StringBuffer buffer)
buffer
- buffer instanceCopyright © 2014 IronJacamar (http://www.ironjacamar.org)