private void runTest2() throws Exception {
    final int MAX_CONNECTIONS = 2;
    logger.debug("runTest2 sleeping");
    Thread.sleep((BLOCKING_TIMEOUT + 2) * 1000);
    DataSource ds = null;
    try {
      Context ctx = cache.getJNDIContext();
      ds = (DataSource) ctx.lookup("java:/XAPooledDataSource");
    } catch (NamingException e) {
      logger.debug("Exception caught during naming lookup: " + e);
      fail("failed in naming lookup: ", e);
    } catch (Exception e) {
      logger.debug("Exception caught during naming lookup: " + e);
      fail("failed in because of unhandled excpetion: ", e);
    }
    try {
      for (int count = 0; count < MAX_CONNECTIONS; count++) {
        Connection con = ds.getConnection();
        assertNotNull("Connection object is null", con);

        logger.debug("runTest2 :acquired connection #" + count);
      }
    } catch (SQLException sqle) {
      logger.debug("SQLException caught in runTest2: " + sqle);
      fail("failed because of SQL exception : ", sqle);
    } catch (Exception e) {
      logger.debug("Exception caught in runTest2: " + e);
      fail("failed because of unhandled exception : ", e);
    }
  }
Return file as string and then modify the string accordingly **
geode-core/src/integrationTest/java/org/apache/geode/internal/jta/BlockingTimeOutJUnitTest.java