Package com.atomikos.jdbc

Examples of com.atomikos.jdbc.XPooledConnection


     */
    public synchronized void connectionClosed ( ConnectionEvent event )
    {
        // called when the Pooled Connection is resubmitted to the pool
        // remove ThreadLocal mapping
        XPooledConnection source = (XPooledConnection) event.getSource ();
        Set values = previousConnections.entrySet ();
        Iterator it = values.iterator ();
        while ( it.hasNext () ) {
            Map.Entry entry = (Map.Entry) it.next ();
            Connection c = (Connection) entry.getValue ();
            ThreadLocalConnection tlc = (ThreadLocalConnection) Proxy
                    .getInvocationHandler ( c );
            if ( tlc.usesConnection ( source ) ) {
                it.remove ();

            }
        }
        source.removeConnectionEventListener ( this );
        pool.putBack ( source );
    }
View Full Code Here


     */
    public synchronized void connectionClosed ( ConnectionEvent event )
    {
        // called when the Pooled Connection is resubmitted to the pool
        // remove ThreadLocal mapping
        XPooledConnection source = (XPooledConnection) event.getSource ();
        Set values = previousConnections.entrySet ();
        Iterator it = values.iterator ();
        while ( it.hasNext () ) {
            Map.Entry entry = (Map.Entry) it.next ();
            Connection c = (Connection) entry.getValue ();
            ThreadLocalConnection tlc = (ThreadLocalConnection) Proxy
                    .getInvocationHandler ( c );
            if ( tlc.usesConnection ( source ) ) {
                it.remove ();

            }
        }
        source.removeConnectionEventListener ( this );
        pool.putBack ( source );
    }
View Full Code Here

     */
    public synchronized void connectionClosed ( ConnectionEvent event )
    {
        // called when the Pooled Connection is resubmitted to the pool
        // remove ThreadLocal mapping
        XPooledConnection source = (XPooledConnection) event.getSource ();
        Set values = previousConnections.entrySet ();
        Iterator it = values.iterator ();
        while ( it.hasNext () ) {
            Map.Entry entry = (Map.Entry) it.next ();
            Connection c = (Connection) entry.getValue ();
            ThreadLocalConnection tlc = (ThreadLocalConnection) Proxy
                    .getInvocationHandler ( c );
            if ( tlc.usesConnection ( source ) ) {
                it.remove ();

            }
        }
        source.removeConnectionEventListener ( this );
        pool.putBack ( source );
    }
View Full Code Here

TOP

Related Classes of com.atomikos.jdbc.XPooledConnection

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.