import org.apache.zookeeper.server.jersey.SetTest.MyWatcher; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
    super.setUp();

    RestCfg cfg = new RestCfg(new ByteArrayInputStream(String.format(
            "rest.port=%s\n" + 
            "rest.endpoint.1=%s;%s\n",
            GRIZZLY_PORT, CONTEXT_PATH, ZKHOSTPORT).getBytes()));

    rest = new RestMain(cfg);
    rest.start();

    zk = new ZooKeeper(ZKHOSTPORT, 30000, new MyWatcher());

    client = Client.create();
    znodesr = client.resource(BASEURI).path("znodes/v1");
    sessionsr = client.resource(BASEURI).path("sessions/v1/");
}
 

import org.apache.zookeeper.server.jersey.SetTest.MyWatcher; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
    RestCfg cfg = new RestCfg(new ByteArrayInputStream(String.format(
            "rest.port=%s\n" + 
            "rest.endpoint.1=%s;%s\n",
            GRIZZLY_PORT, CONTEXT_PATH, ZKHOSTPORT).getBytes()));

    rest = new RestMain(cfg);
    rest.start();

    zk = new ZooKeeper(ZKHOSTPORT, 30000, new MyWatcher());

    client = Client.create();
    znodesr = client.resource(BASEURI).path("znodes/v1");
    sessionsr = client.resource(BASEURI).path("sessions/v1/");
}
 

import org.apache.zookeeper.server.jersey.SetTest.MyWatcher; //导入依赖的package包/类
protected static String createBaseZNode() throws Exception {
    ZooKeeper zk = new ZooKeeper(ZKHOSTPORT, 30000, new MyWatcher());

    String baseZnode = zk.create("/test-", null, Ids.OPEN_ACL_UNSAFE,
            CreateMode.PERSISTENT_SEQUENTIAL);
    zk.close();

    return baseZnode;
}
 

import org.apache.zookeeper.server.jersey.SetTest.MyWatcher; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
    super.setUp();

    ZooKeeperService.mapUriBase(BASEURI, ZKHOSTPORT);

    RestMain main = new RestMain(BASEURI);
    threadSelector = main.execute();

    zk = new ZooKeeper(ZKHOSTPORT, 30000, new MyWatcher());

    c = Client.create();
    r = c.resource(BASEURI);
    r = r.path("znodes/v1");
}