try
        {
            con = connector.getConnection();
            do
            {
                ....
                result = connector.getQueryRunner().query(con, readStmt, params, connector.getResultSetHandler());
                if (result != null)
                {
                    if (staticLogger.isDebugEnabled())
                    {
                        staticLogger.debug("Received: " + result);
                    }
                    break;
                }
                final long sleep = Math.min(connector.getPollingFrequency(), timeout
                    - (System.currentTimeMillis() - t0));
                if (sleep > 0)
                {
                    ....
                    Thread.sleep(sleep);
                }
                else
                {
                    staticLogger.debug("Timeout");  // also, its not really a Timeout, it could just mean that there are not results
                    return null; // Connection Leak!  Call JDBCUtils.commitAndClose(con)?
                }
            }
            while (true);

            ....
            JdbcUtils.commitAndClose(con);
            return message;
        }
        catch (final Exception e)
        {
            JdbcUtils.rollbackAndClose(con);
            throw e;
        }

public Connection getConnection() throws Exception
    {
        Transaction tx = TransactionCoordination.getInstance().getTransaction();
        if (tx != null)
        {
            if (tx.hasResource(dataSource))
            {
                logger.debug("Retrieving connection from current transaction");
                return (Connection)tx.getResource(dataSource);
            }
        }
        logger.debug("Retrieving new connection from data source");
        Connection con = dataSource.getConnection();

        if (tx != null)
        {
            logger.debug("Binding connection to current transaction");
            try
            {
                tx.bindResource(dataSource, con);
            }
            catch (TransactionException e)
            {
 // Connection leak!  Call JDBCUtils.close(con)?
                throw new RuntimeException("Could not bind connection to current transaction", e);
            }
        }
        return con;
    }