1. 包列表
  2. 类列表
  3. org.apache.zookeeper.server.jersey.jaxb.ZPath

Java 类org.apache.zookeeper.server.jersey.jaxb.ZPath 实例源码

项目：https-github.com-apache-zookeeper    文件：RootTest.java    
@Test
public void testCreate() throws Exception {
    String path = "/";
    String name = "roottest-create";
    byte[] data = "foo".getBytes();

    WebResource wr = znodesr.path(path).queryParam("dataformat", "utf8")
        .queryParam("name", name);
    Builder builder = wr.accept(MediaType.APPLICATION_JSON);

    ClientResponse cr;
    cr = builder.post(ClientResponse.class, data);
    Assert.assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());

    ZPath zpath = cr.getEntity(ZPath.class);
    Assert.assertEquals(new ZPath(path + name), zpath);
    Assert.assertEquals(znodesr.path(path).toString(), zpath.uri);

    // use out-of-band method to verify
    byte[] rdata = zk.getData(zpath.path, false, new Stat());
    Assert.assertTrue(new String(rdata) + " == " + new String(data),
            Arrays.equals(rdata, data));
}
项目：ZooKeeper    文件：RootTest.java    
@Test
public void testCreate() throws Exception {
    LOG.info("STARTING " + getName());

    String path = "/";
    String name = "roottest-create";
    byte[] data = "foo".getBytes();

    WebResource wr = znodesr.path(path).queryParam("dataformat", "utf8")
        .queryParam("name", name);
    Builder builder = wr.accept(MediaType.APPLICATION_JSON);

    ClientResponse cr;
    cr = builder.post(ClientResponse.class, data);
    assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());

    ZPath zpath = cr.getEntity(ZPath.class);
    assertEquals(new ZPath(path + name), zpath);
    assertEquals(znodesr.path(path).toString(), zpath.uri);

    // use out-of-band method to verify
    byte[] rdata = zk.getData(zpath.path, false, new Stat());
    assertTrue(new String(rdata) + " == " + new String(data),
            Arrays.equals(rdata, data));
}
项目：fuck_zookeeper    文件：JAXBContextResolver.java    
public JAXBContextResolver() throws Exception {
    Class[] typesArr =
        new Class[]{ZPath.class, ZStat.class, ZChildrenJSON.class};
    typesSet = new HashSet<Class>(Arrays.asList(typesArr));
    context = new JSONJAXBContext(
            JSONConfiguration.mapped()
                .arrays("children")
                .nonStrings("czxid")
                .nonStrings("mzxid")
                .nonStrings("ctime")
                .nonStrings("mtime")
                .nonStrings("version")
                .nonStrings("cversion")
                .nonStrings("aversion")
                .nonStrings("ephemeralOwner")
                .nonStrings("dataLength")
                .nonStrings("numChildren")
                .nonStrings("pzxid")
                .build(),
            typesArr);
}
项目：fuck_zookeeper    文件：RootTest.java    
@Test
public void testCreate() throws Exception {
    LOG.info("STARTING " + getName());

    String path = "/";
    String name = "roottest-create";
    byte[] data = "foo".getBytes();

    WebResource wr = znodesr.path(path).queryParam("dataformat", "utf8")
        .queryParam("name", name);
    Builder builder = wr.accept(MediaType.APPLICATION_JSON);

    ClientResponse cr;
    cr = builder.post(ClientResponse.class, data);
    assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());

    ZPath zpath = cr.getEntity(ZPath.class);
    assertEquals(new ZPath(path + name), zpath);
    assertEquals(znodesr.path(path).toString(), zpath.uri);

    // use out-of-band method to verify
    byte[] rdata = zk.getData(zpath.path, false, new Stat());
    assertTrue(new String(rdata) + " == " + new String(data),
            Arrays.equals(rdata, data));
}
项目：https-github.com-apache-zookeeper    文件：JAXBContextResolver.java    
public JAXBContextResolver() throws Exception {
    Class[] typesArr =
        new Class[]{ZPath.class, ZStat.class, ZChildrenJSON.class};
    typesSet = new HashSet<Class>(Arrays.asList(typesArr));
    context = new JSONJAXBContext(
            JSONConfiguration.mapped()
                .arrays("children")
                .nonStrings("czxid")
                .nonStrings("mzxid")
                .nonStrings("ctime")
                .nonStrings("mtime")
                .nonStrings("version")
                .nonStrings("cversion")
                .nonStrings("aversion")
                .nonStrings("ephemeralOwner")
                .nonStrings("dataLength")
                .nonStrings("numChildren")
                .nonStrings("pzxid")
                .build(),
            typesArr);
}
项目：ZooKeeper    文件：JAXBContextResolver.java    
public JAXBContextResolver() throws Exception {
    Class[] typesArr =
        new Class[]{ZPath.class, ZStat.class, ZChildrenJSON.class};
    typesSet = new HashSet<Class>(Arrays.asList(typesArr));
    context = new JSONJAXBContext(
            JSONConfiguration.mapped()
                .arrays("children")
                .nonStrings("czxid")
                .nonStrings("mzxid")
                .nonStrings("ctime")
                .nonStrings("mtime")
                .nonStrings("version")
                .nonStrings("cversion")
                .nonStrings("aversion")
                .nonStrings("ephemeralOwner")
                .nonStrings("dataLength")
                .nonStrings("numChildren")
                .nonStrings("pzxid")
                .build(),
            typesArr);
}
项目：StreamProcessingInfrastructure    文件：JAXBContextResolver.java    
public JAXBContextResolver() throws Exception {
    Class[] typesArr =
        new Class[]{ZPath.class, ZStat.class, ZChildrenJSON.class};
    typesSet = new HashSet<Class>(Arrays.asList(typesArr));
    context = new JSONJAXBContext(
            JSONConfiguration.mapped()
                .arrays("children")
                .nonStrings("czxid")
                .nonStrings("mzxid")
                .nonStrings("ctime")
                .nonStrings("mtime")
                .nonStrings("version")
                .nonStrings("cversion")
                .nonStrings("aversion")
                .nonStrings("ephemeralOwner")
                .nonStrings("dataLength")
                .nonStrings("numChildren")
                .nonStrings("pzxid")
                .build(),
            typesArr);
}
项目：StreamProcessingInfrastructure    文件：RootTest.java    
@Test
public void testCreate() throws Exception {
    LOG.info("STARTING " + getName());

    String path = "/";
    String name = "roottest-create";
    byte[] data = "foo".getBytes();

    WebResource wr = znodesr.path(path).queryParam("dataformat", "utf8")
        .queryParam("name", name);
    Builder builder = wr.accept(MediaType.APPLICATION_JSON);

    ClientResponse cr;
    cr = builder.post(ClientResponse.class, data);
    assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());

    ZPath zpath = cr.getEntity(ZPath.class);
    assertEquals(new ZPath(path + name), zpath);
    assertEquals(znodesr.path(path).toString(), zpath.uri);

    // use out-of-band method to verify
    byte[] rdata = zk.getData(zpath.path, false, new Stat());
    assertTrue(new String(rdata) + " == " + new String(data),
            Arrays.equals(rdata, data));
}
项目：bigstreams    文件：JAXBContextResolver.java    
public JAXBContextResolver() throws Exception {
    Class[] typesArr =
        new Class[]{ZPath.class, ZStat.class, ZChildrenJSON.class};
    typesSet = new HashSet<Class>(Arrays.asList(typesArr));
    context = new JSONJAXBContext(
            JSONConfiguration.mapped()
                .arrays("children")
                .nonStrings("czxid")
                .nonStrings("mzxid")
                .nonStrings("ctime")
                .nonStrings("mtime")
                .nonStrings("version")
                .nonStrings("cversion")
                .nonStrings("aversion")
                .nonStrings("ephemeralOwner")
                .nonStrings("dataLength")
                .nonStrings("numChildren")
                .nonStrings("pzxid")
                .build(),
            typesArr);
}
项目：bigstreams    文件：RootTest.java    
@Test
public void testCreate() throws Exception {
    LOG.info("STARTING " + getName());

    String path = "/";
    String name = "roottest-create";
    byte[] data = "foo".getBytes();

    WebResource wr = znodesr.path(path).queryParam("dataformat", "utf8")
        .queryParam("name", name);
    Builder builder = wr.accept(MediaType.APPLICATION_JSON);

    ClientResponse cr;
    cr = builder.post(ClientResponse.class, data);
    assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());

    ZPath zpath = cr.getEntity(ZPath.class);
    assertEquals(new ZPath(path + name), zpath);
    assertEquals(znodesr.path(path).toString(), zpath.uri);

    // use out-of-band method to verify
    byte[] rdata = zk.getData(zpath.path, false, new Stat());
    assertTrue(new String(rdata) + " == " + new String(data),
            Arrays.equals(rdata, data));
}
项目：bigstreams    文件：JAXBContextResolver.java    
public JAXBContextResolver() throws Exception {
    Class[] typesArr =
        new Class[]{ZPath.class, ZStat.class, ZChildrenJSON.class};
    typesSet = new HashSet<Class>(Arrays.asList(typesArr));
    context = new JSONJAXBContext(
            JSONConfiguration.mapped()
                .arrays("children")
                .nonStrings("czxid")
                .nonStrings("mzxid")
                .nonStrings("ctime")
                .nonStrings("mtime")
                .nonStrings("version")
                .nonStrings("cversion")
                .nonStrings("aversion")
                .nonStrings("ephemeralOwner")
                .nonStrings("dataLength")
                .nonStrings("numChildren")
                .nonStrings("pzxid")
                .build(),
            typesArr);
}
项目：bigstreams    文件：RootTest.java    
@Test
public void testCreate() throws Exception {
    LOG.info("STARTING " + getName());

    String path = "/";
    String name = "roottest-create";
    byte[] data = "foo".getBytes();

    WebResource wr = znodesr.path(path).queryParam("dataformat", "utf8")
        .queryParam("name", name);
    Builder builder = wr.accept(MediaType.APPLICATION_JSON);

    ClientResponse cr;
    cr = builder.post(ClientResponse.class, data);
    assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());

    ZPath zpath = cr.getEntity(ZPath.class);
    assertEquals(new ZPath(path + name), zpath);
    assertEquals(znodesr.path(path).toString(), zpath.uri);

    // use out-of-band method to verify
    byte[] rdata = zk.getData(zpath.path, false, new Stat());
    assertTrue(new String(rdata) + " == " + new String(data),
            Arrays.equals(rdata, data));
}
项目：SecureKeeper    文件：JAXBContextResolver.java    
public JAXBContextResolver() throws Exception {
    Class[] typesArr =
        new Class[]{ZPath.class, ZStat.class, ZChildrenJSON.class};
    typesSet = new HashSet<Class>(Arrays.asList(typesArr));
    context = new JSONJAXBContext(
            JSONConfiguration.mapped()
                .arrays("children")
                .nonStrings("czxid")
                .nonStrings("mzxid")
                .nonStrings("ctime")
                .nonStrings("mtime")
                .nonStrings("version")
                .nonStrings("cversion")
                .nonStrings("aversion")
                .nonStrings("ephemeralOwner")
                .nonStrings("dataLength")
                .nonStrings("numChildren")
                .nonStrings("pzxid")
                .build(),
            typesArr);
}
项目：SecureKeeper    文件：RootTest.java    
@Test
public void testCreate() throws Exception {
    String path = "/";
    String name = "roottest-create";
    byte[] data = "foo".getBytes();

    WebResource wr = znodesr.path(path).queryParam("dataformat", "utf8")
        .queryParam("name", name);
    Builder builder = wr.accept(MediaType.APPLICATION_JSON);

    ClientResponse cr;
    cr = builder.post(ClientResponse.class, data);
    Assert.assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());

    ZPath zpath = cr.getEntity(ZPath.class);
    Assert.assertEquals(new ZPath(path + name), zpath);
    Assert.assertEquals(znodesr.path(path).toString(), zpath.uri);

    // use out-of-band method to verify
    byte[] rdata = zk.getData(zpath.path, false, new Stat());
    Assert.assertTrue(new String(rdata) + " == " + new String(data),
            Arrays.equals(rdata, data));
}
项目：SecureKeeper    文件：JAXBContextResolver.java    
public JAXBContextResolver() throws Exception {
    Class[] typesArr =
        new Class[]{ZPath.class, ZStat.class, ZChildrenJSON.class};
    typesSet = new HashSet<Class>(Arrays.asList(typesArr));
    context = new JSONJAXBContext(
            JSONConfiguration.mapped()
                .arrays("children")
                .nonStrings("czxid")
                .nonStrings("mzxid")
                .nonStrings("ctime")
                .nonStrings("mtime")
                .nonStrings("version")
                .nonStrings("cversion")
                .nonStrings("aversion")
                .nonStrings("ephemeralOwner")
                .nonStrings("dataLength")
                .nonStrings("numChildren")
                .nonStrings("pzxid")
                .build(),
            typesArr);
}
项目：SecureKeeper    文件：RootTest.java    
@Test
public void testCreate() throws Exception {
    String path = "/";
    String name = "roottest-create";
    byte[] data = "foo".getBytes();

    WebResource wr = znodesr.path(path).queryParam("dataformat", "utf8")
        .queryParam("name", name);
    Builder builder = wr.accept(MediaType.APPLICATION_JSON);

    ClientResponse cr;
    cr = builder.post(ClientResponse.class, data);
    Assert.assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());

    ZPath zpath = cr.getEntity(ZPath.class);
    Assert.assertEquals(new ZPath(path + name), zpath);
    Assert.assertEquals(znodesr.path(path).toString(), zpath.uri);

    // use out-of-band method to verify
    byte[] rdata = zk.getData(zpath.path, false, new Stat());
    Assert.assertTrue(new String(rdata) + " == " + new String(data),
            Arrays.equals(rdata, data));
}
项目：StreamBench    文件：JAXBContextResolver.java    
public JAXBContextResolver() throws Exception {
    Class[] typesArr =
        new Class[]{ZPath.class, ZStat.class, ZChildrenJSON.class};
    typesSet = new HashSet<Class>(Arrays.asList(typesArr));
    context = new JSONJAXBContext(
            JSONConfiguration.mapped()
                .arrays("children")
                .nonStrings("czxid")
                .nonStrings("mzxid")
                .nonStrings("ctime")
                .nonStrings("mtime")
                .nonStrings("version")
                .nonStrings("cversion")
                .nonStrings("aversion")
                .nonStrings("ephemeralOwner")
                .nonStrings("dataLength")
                .nonStrings("numChildren")
                .nonStrings("pzxid")
                .build(),
            typesArr);
}
项目：StreamBench    文件：RootTest.java    
@Test
public void testCreate() throws Exception {
    LOG.info("STARTING " + getName());

    String path = "/";
    String name = "roottest-create";
    byte[] data = "foo".getBytes();

    WebResource wr = znodesr.path(path).queryParam("dataformat", "utf8")
        .queryParam("name", name);
    Builder builder = wr.accept(MediaType.APPLICATION_JSON);

    ClientResponse cr;
    cr = builder.post(ClientResponse.class, data);
    assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());

    ZPath zpath = cr.getEntity(ZPath.class);
    assertEquals(new ZPath(path + name), zpath);
    assertEquals(znodesr.path(path).toString(), zpath.uri);

    // use out-of-band method to verify
    byte[] rdata = zk.getData(zpath.path, false, new Stat());
    assertTrue(new String(rdata) + " == " + new String(data),
            Arrays.equals(rdata, data));
}
项目：LoadBalanced_zk    文件：JAXBContextResolver.java    
public JAXBContextResolver() throws Exception {
    Class[] typesArr =
        new Class[]{ZPath.class, ZStat.class, ZChildrenJSON.class};
    typesSet = new HashSet<Class>(Arrays.asList(typesArr));
    context = new JSONJAXBContext(
            JSONConfiguration.mapped()
                .arrays("children")
                .nonStrings("czxid")
                .nonStrings("mzxid")
                .nonStrings("ctime")
                .nonStrings("mtime")
                .nonStrings("version")
                .nonStrings("cversion")
                .nonStrings("aversion")
                .nonStrings("ephemeralOwner")
                .nonStrings("dataLength")
                .nonStrings("numChildren")
                .nonStrings("pzxid")
                .build(),
            typesArr);
}
项目：LoadBalanced_zk    文件：RootTest.java    
@Test
public void testCreate() throws Exception {
    LOG.info("STARTING " + getName());

    String path = "/";
    String name = "roottest-create";
    byte[] data = "foo".getBytes();

    WebResource wr = znodesr.path(path).queryParam("dataformat", "utf8")
        .queryParam("name", name);
    Builder builder = wr.accept(MediaType.APPLICATION_JSON);

    ClientResponse cr;
    cr = builder.post(ClientResponse.class, data);
    assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());

    ZPath zpath = cr.getEntity(ZPath.class);
    assertEquals(new ZPath(path + name), zpath);
    assertEquals(znodesr.path(path).toString(), zpath.uri);

    // use out-of-band method to verify
    byte[] rdata = zk.getData(zpath.path, false, new Stat());
    assertTrue(new String(rdata) + " == " + new String(data),
            Arrays.equals(rdata, data));
}
项目：LoadBalanced_zk    文件：JAXBContextResolver.java    
public JAXBContextResolver() throws Exception {
    Class[] typesArr =
        new Class[]{ZPath.class, ZStat.class, ZChildrenJSON.class};
    typesSet = new HashSet<Class>(Arrays.asList(typesArr));
    context = new JSONJAXBContext(
            JSONConfiguration.mapped()
                .arrays("children")
                .nonStrings("czxid")
                .nonStrings("mzxid")
                .nonStrings("ctime")
                .nonStrings("mtime")
                .nonStrings("version")
                .nonStrings("cversion")
                .nonStrings("aversion")
                .nonStrings("ephemeralOwner")
                .nonStrings("dataLength")
                .nonStrings("numChildren")
                .nonStrings("pzxid")
                .build(),
            typesArr);
}
项目：LoadBalanced_zk    文件：RootTest.java    
@Test
public void testCreate() throws Exception {
    LOG.info("STARTING " + getName());

    String path = "/";
    String name = "roottest-create";
    byte[] data = "foo".getBytes();

    WebResource wr = znodesr.path(path).queryParam("dataformat", "utf8")
        .queryParam("name", name);
    Builder builder = wr.accept(MediaType.APPLICATION_JSON);

    ClientResponse cr;
    cr = builder.post(ClientResponse.class, data);
    assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());

    ZPath zpath = cr.getEntity(ZPath.class);
    assertEquals(new ZPath(path + name), zpath);
    assertEquals(znodesr.path(path).toString(), zpath.uri);

    // use out-of-band method to verify
    byte[] rdata = zk.getData(zpath.path, false, new Stat());
    assertTrue(new String(rdata) + " == " + new String(data),
            Arrays.equals(rdata, data));
}
项目：zookeeper.dsc    文件：JAXBContextResolver.java    
public JAXBContextResolver() throws Exception {
    Class[] typesArr =
        new Class[]{ZPath.class, ZStat.class, ZChildrenJSON.class};
    typesSet = new HashSet<Class>(Arrays.asList(typesArr));
    context = new JSONJAXBContext(
            JSONConfiguration.mapped()
                .arrays("children")
                .nonStrings("czxid")
                .nonStrings("mzxid")
                .nonStrings("ctime")
                .nonStrings("mtime")
                .nonStrings("version")
                .nonStrings("cversion")
                .nonStrings("aversion")
                .nonStrings("ephemeralOwner")
                .nonStrings("dataLength")
                .nonStrings("numChildren")
                .nonStrings("pzxid")
                .build(),
            typesArr);
}
项目：zookeeper.dsc    文件：RootTest.java    
@Test
public void testCreate() throws Exception {
    LOG.info("STARTING " + getName());

    String path = "/";
    String name = "roottest-create";
    byte[] data = "foo".getBytes();

    WebResource wr = r.path(path).queryParam("dataformat", "utf8")
        .queryParam("name", name);
    Builder builder = wr.accept(MediaType.APPLICATION_JSON);

    ClientResponse cr;
    cr = builder.post(ClientResponse.class, data);
    assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());

    ZPath zpath = cr.getEntity(ZPath.class);
    assertEquals(new ZPath(path + name), zpath);
    assertEquals(r.path(path).toString(), zpath.uri);

    // use out-of-band method to verify
    byte[] rdata = zk.getData(zpath.path, false, new Stat());
    assertTrue(new String(rdata) + " == " + new String(data),
            Arrays.equals(rdata, data));
}
项目：zookeeper-pkg    文件：JAXBContextResolver.java    
public JAXBContextResolver() throws Exception {
    Class[] typesArr =
        new Class[]{ZPath.class, ZStat.class, ZChildrenJSON.class};
    typesSet = new HashSet<Class>(Arrays.asList(typesArr));
    context = new JSONJAXBContext(
            JSONConfiguration.mapped()
                .arrays("children")
                .nonStrings("czxid")
                .nonStrings("mzxid")
                .nonStrings("ctime")
                .nonStrings("mtime")
                .nonStrings("version")
                .nonStrings("cversion")
                .nonStrings("aversion")
                .nonStrings("ephemeralOwner")
                .nonStrings("dataLength")
                .nonStrings("numChildren")
                .nonStrings("pzxid")
                .build(),
            typesArr);
}
项目：zookeeper-pkg    文件：RootTest.java    
@Test
public void testCreate() throws Exception {
    LOG.info("STARTING " + getName());

    String path = "/";
    String name = "roottest-create";
    byte[] data = "foo".getBytes();

    WebResource wr = znodesr.path(path).queryParam("dataformat", "utf8")
        .queryParam("name", name);
    Builder builder = wr.accept(MediaType.APPLICATION_JSON);

    ClientResponse cr;
    cr = builder.post(ClientResponse.class, data);
    assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());

    ZPath zpath = cr.getEntity(ZPath.class);
    assertEquals(new ZPath(path + name), zpath);
    assertEquals(znodesr.path(path).toString(), zpath.uri);

    // use out-of-band method to verify
    byte[] rdata = zk.getData(zpath.path, false, new Stat());
    assertTrue(new String(rdata) + " == " + new String(data),
            Arrays.equals(rdata, data));
}
项目：fuck_zookeeper    文件：CreateTest.java    
@Parameters
public static Collection<Object[]> data() throws Exception {
    String baseZnode = Base.createBaseZNode();

    return Arrays.asList(new Object[][] {
      {MediaType.APPLICATION_JSON,
          baseZnode, "foo bar", "utf8",
          ClientResponse.Status.CREATED,
          new ZPath(baseZnode + "/foo bar"), null,
          false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t1"),
          null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t2"),
          "".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t3"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t4", "base64",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t4"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true }
      });
}
项目：fuck_zookeeper    文件：CreateTest.java    
public CreateTest(String accept, String path, String name, String encoding,
        ClientResponse.Status status, ZPath expectedPath, byte[] data,
        boolean sequence)
{
    this.accept = accept;
    this.path = path;
    this.name = name;
    this.encoding = encoding;
    this.expectedStatus = status;
    this.expectedPath = expectedPath;
    this.data = data;
    this.sequence = sequence;
}
项目：https-github.com-apache-zookeeper    文件：CreateTest.java    
@Parameters
public static Collection<Object[]> data() throws Exception {
    String baseZnode = Base.createBaseZNode();

    return Arrays.asList(new Object[][] {
      {MediaType.APPLICATION_JSON,
          baseZnode, "foo bar", "utf8",
          ClientResponse.Status.CREATED,
          new ZPath(baseZnode + "/foo bar"), null,
          false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t1"),
          null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t2"),
          "".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t3"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t4", "base64",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t4"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true }
      });
}
项目：https-github.com-apache-zookeeper    文件：CreateTest.java    
public CreateTest(String accept, String path, String name, String encoding,
        ClientResponse.Status status, ZPath expectedPath, byte[] data,
        boolean sequence)
{
    this.accept = accept;
    this.path = path;
    this.name = name;
    this.encoding = encoding;
    this.expectedStatus = status;
    this.expectedPath = expectedPath;
    this.data = data;
    this.sequence = sequence;
}
项目：ZooKeeper    文件：CreateTest.java    
@Parameters
public static Collection<Object[]> data() throws Exception {
    String baseZnode = Base.createBaseZNode();

    return Arrays.asList(new Object[][] {
      {MediaType.APPLICATION_JSON,
          baseZnode, "foo bar", "utf8",
          ClientResponse.Status.CREATED,
          new ZPath(baseZnode + "/foo bar"), null,
          false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t1"),
          null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t2"),
          "".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t3"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t4", "base64",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t4"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true }
      });
}
项目：ZooKeeper    文件：CreateTest.java    
public CreateTest(String accept, String path, String name, String encoding,
        ClientResponse.Status status, ZPath expectedPath, byte[] data,
        boolean sequence)
{
    this.accept = accept;
    this.path = path;
    this.name = name;
    this.encoding = encoding;
    this.expectedStatus = status;
    this.expectedPath = expectedPath;
    this.data = data;
    this.sequence = sequence;
}
项目：StreamProcessingInfrastructure    文件：CreateTest.java    
@Parameters
public static Collection<Object[]> data() throws Exception {
    String baseZnode = Base.createBaseZNode();

    return Arrays.asList(new Object[][] {
      {MediaType.APPLICATION_JSON,
          baseZnode, "foo bar", "utf8",
          ClientResponse.Status.CREATED,
          new ZPath(baseZnode + "/foo bar"), null,
          false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t1"),
          null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t2"),
          "".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t3"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t4", "base64",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t4"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true }
      });
}
项目：StreamProcessingInfrastructure    文件：CreateTest.java    
public CreateTest(String accept, String path, String name, String encoding,
        ClientResponse.Status status, ZPath expectedPath, byte[] data,
        boolean sequence)
{
    this.accept = accept;
    this.path = path;
    this.name = name;
    this.encoding = encoding;
    this.expectedStatus = status;
    this.expectedPath = expectedPath;
    this.data = data;
    this.sequence = sequence;
}
项目：bigstreams    文件：CreateTest.java    
@Parameters
public static Collection<Object[]> data() throws Exception {
    String baseZnode = Base.createBaseZNode();

    return Arrays.asList(new Object[][] {
      {MediaType.APPLICATION_JSON,
          baseZnode, "foo bar", "utf8",
          ClientResponse.Status.CREATED,
          new ZPath(baseZnode + "/foo bar"), null,
          false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t1"),
          null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t2"),
          "".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t3"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t4", "base64",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t4"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true }
      });
}
项目：bigstreams    文件：CreateTest.java    
public CreateTest(String accept, String path, String name, String encoding,
        ClientResponse.Status status, ZPath expectedPath, byte[] data,
        boolean sequence)
{
    this.accept = accept;
    this.path = path;
    this.name = name;
    this.encoding = encoding;
    this.expectedStatus = status;
    this.expectedPath = expectedPath;
    this.data = data;
    this.sequence = sequence;
}
项目：bigstreams    文件：CreateTest.java    
@Parameters
public static Collection<Object[]> data() throws Exception {
    String baseZnode = Base.createBaseZNode();

    return Arrays.asList(new Object[][] {
      {MediaType.APPLICATION_JSON,
          baseZnode, "foo bar", "utf8",
          ClientResponse.Status.CREATED,
          new ZPath(baseZnode + "/foo bar"), null,
          false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t1"),
          null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t2"),
          "".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t3"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t4", "base64",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t4"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true }
      });
}
项目：bigstreams    文件：CreateTest.java    
public CreateTest(String accept, String path, String name, String encoding,
        ClientResponse.Status status, ZPath expectedPath, byte[] data,
        boolean sequence)
{
    this.accept = accept;
    this.path = path;
    this.name = name;
    this.encoding = encoding;
    this.expectedStatus = status;
    this.expectedPath = expectedPath;
    this.data = data;
    this.sequence = sequence;
}
项目：SecureKeeper    文件：CreateTest.java    
@Parameters
public static Collection<Object[]> data() throws Exception {
    String baseZnode = Base.createBaseZNode();

    return Arrays.asList(new Object[][] {
      {MediaType.APPLICATION_JSON,
          baseZnode, "foo bar", "utf8",
          ClientResponse.Status.CREATED,
          new ZPath(baseZnode + "/foo bar"), null,
          false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t1"),
          null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t1", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t2"),
          "".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t2", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t3"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t3", "utf8",
          ClientResponse.Status.CONFLICT, null, null, false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-t4", "base64",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-t4"),
          "foo".getBytes(), false },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true },
      {MediaType.APPLICATION_JSON, baseZnode, "c-", "utf8",
          ClientResponse.Status.CREATED, new ZPath(baseZnode + "/c-"), null,
          true }
      });
}
项目：SecureKeeper    文件：CreateTest.java    
public CreateTest(String accept, String path, String name, String encoding,
        ClientResponse.Status status, ZPath expectedPath, byte[] data,
        boolean sequence)
{
    this.accept = accept;
    this.path = path;
    this.name = name;
    this.encoding = encoding;
    this.expectedStatus = status;
    this.expectedPath = expectedPath;
    this.data = data;
    this.sequence = sequence;
}