}
        catch ( TimeoutException e ) {
            log.info("Timeout waiting", e);
            fail("Did not recieve notification");
        }

    }


    @Test
    public void testWatchClose () throws InterruptedException, ExecutionException, IOException, TimeoutException {