gistfile1.java

    public static void main(String[] args) throws Exception
    {
        TestingServer server = new TestingServer();

        final CountDownLatch latch = new CountDownLatch(1);
        Watcher watcher = new Watcher()
        {
            @Override
            public void process(WatchedEvent event)
            {
                if ( event.getState() == Event.KeeperState.SyncConnected )
                {
                    latch.countDown();
                }
            }
        };
        ZooKeeper zooKeeper = new ZooKeeper(server.getConnectString(), 1000, watcher);
        latch.await();

        zooKeeper.create("/test", new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        final AtomicBoolean fired = new AtomicBoolean(false);
        Watcher existsWatcher = new Watcher()
        {
            @Override
            public void process(WatchedEvent event)
            {
                if ( event.getType() == Event.EventType.NodeDeleted )
                {
                    fired.set(true);
                }
            }
        };
        zooKeeper.exists("/test", existsWatcher);
        zooKeeper.delete("/test", -1);

        Thread.sleep(3000);

        System.err.println("Fired: " + fired.get());

        zooKeeper.close();
        server.close();
    }