Examples of javax.sql.PooledConnection.addConnectionEventListener()

javax.sql.PooledConnection.addConnectionEventListener()
Registers the supplied ConnectionEventListener with this PooledConnection. Once registered, the ConnectionEventListener will receive ConnectionEvent events when they occur in the PooledConnection. @param theListener an object which implements the ConnectionEventListener interface.

                        
                        if (throwableHolder != EMPTY_THROWABLE_HOLDER)
                            thp.returnThrowableHolder( throwableHolder );
                        
                        ConnectionUtils.attemptClose( conn ); //invalidate proxy connection
                        pc.addConnectionEventListener( cl );  //should we move this to CONNECTION_IS_OKAY case? (it should work either way)
                    }


                    switch (status)
                    {
                    case ConnectionTester.CONNECTION_IS_OKAY:

View Full Code Here

                        {
                            //invalidate the proxy Connection
                            ConnectionUtils.attemptClose( con );
                        }
                        
                        out.addConnectionEventListener( cl );
                        return out;
                    }
                    catch (Exception e)
                    {
                        if (logger.isLoggable( MLevel.WARNING ))

View Full Code Here

                        finally
                        {
                            // close the proxy Connection
                            ConnectionUtils.attemptClose(con);
                            
                            pc.addConnectionEventListener( cl );
                        }
                    }
                    
                    if ( testConnectionOnCheckin )
                    {

View Full Code Here

                        
                        if (throwableHolder != EMPTY_THROWABLE_HOLDER)
                            thp.returnThrowableHolder( throwableHolder );
                        
                        ConnectionUtils.attemptClose( conn ); //invalidate proxy connection
                        pc.addConnectionEventListener( cl );  //should we move this to CONNECTION_IS_OKAY case? (it should work either way)
                    }


                    switch (status)
                    {
                    case ConnectionTester.CONNECTION_IS_OKAY:

View Full Code Here

        } else {
            pc = _cpds.getPooledConnection(username, password);
        }
        // should we add this object as a listener or the pool.
        // consider the validateObject method in decision
        pc.addConnectionEventListener(this);
        obj = new PooledConnectionAndInfo(pc, username, password);
        pcMap.put(pc, obj);


        return obj;
    }

View Full Code Here

            } else {
                pc = _cpds.getPooledConnection(_username, _password);
            }
            // should we add this object as a listener or the pool.
            // consider the validateObject method in decision
            pc.addConnectionEventListener(this);
            obj = new PooledConnectionAndInfo(pc, _username, _password);
            pcMap.put(pc, obj);
        } catch (SQLException e) {
            throw new RuntimeException(e.getMessage());
        }

View Full Code Here

            throw new IllegalStateException("Connection pool data source returned null from getPooledConnection");
        }


        // should we add this object as a listener or the pool.
        // consider the validateObject method in decision
        pc.addConnectionEventListener(this);
        obj = new PooledConnectionAndInfo(pc, username, password);
        pcMap.put(pc, obj);


        return obj;
    }

View Full Code Here

                throw new IllegalStateException("Connection pool data source returned null from getPooledConnection");
            }


            // should we add this object as a listener or the pool.
            // consider the validateObject method in decision
            pc.addConnectionEventListener(this);
            obj = new PooledConnectionAndInfo(pc, _username, _password);
            pcMap.put(pc, obj);
        } catch (SQLException e) {
            throw new RuntimeException(e.getMessage());
        }

View Full Code Here

            {
                pc = _cpds.getPooledConnection(username, upkey.getPassword());
            }
            // should we add this object as a listener or the pool.
            // consider the validateObject method in decision
            pc.addConnectionEventListener(this);
            pcKeyMap.put(pc, key);
        }
        catch (SQLException e)
        {
            throw new RuntimeException(e.getMessage());

View Full Code Here

            {
                pc = _cpds.getPooledConnection(_username, _password);
            }
            // should we add this object as a listener or the pool.
            // consider the validateObject method in decision
            pc.addConnectionEventListener(this);
        }
        catch (SQLException e)
        {
            throw new RuntimeException(e.getMessage());
        }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.