class AthenzDataSource extends PoolingDataSource<PoolableConnection> implements PoolableDataSource {

    @Override
    synchronized public void clearPoolConnections() {
        ObjectPool<PoolableConnection> pool = getPool();
        try {
            LOG.info("Clearing all active/idle ({}/{}) connections from the pool",
                    pool.getNumActive(), pool.getNumIdle());
            pool.clear();
        } catch (Exception ex) {
            LOG.error("Unable to clear connections from the pool", ex);
        }
    }

    public  AthenzDataSource(ObjectPool<PoolableConnection> pool);

}