@Override public void process() { called.set(true); }
};
// now accessing the cluster should get us an error.
boolean gotCorrectError = false;
try { session.getSubdirs(clusterId.asPath(), callback); } catch (ClusterInfoException e) { gotCorrectError = true; }
assertTrue(gotCorrectError);
// now lets startup the server.
ZookeeperTestServer server = null;
try