本文整理汇总了Java中org.apache.zookeeper.server.jersey.jaxb.ZPath类的典型用法代码示例。如果您正苦于以下问题:Java ZPath类的具体用法?Java ZPath怎么用?Java ZPath使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ZPath类属于org.apache.zookeeper.server.jersey.jaxb包,在下文中一共展示了ZPath类的6个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testCreate
import org.apache.zookeeper.server.jersey.jaxb.ZPath; //导入依赖的package包/类
@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));
}
开发者ID:l294265421,项目名称:ZooKeeper,代码行数:26,代码来源:RootTest.java
示例2: JAXBContextResolver
import org.apache.zookeeper.server.jersey.jaxb.ZPath; //导入依赖的package包/类
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);
}
开发者ID:maoling,项目名称:fuck_zookeeper,代码行数:22,代码来源:JAXBContextResolver.java
示例3: testCreate
import org.apache.zookeeper.server.jersey.jaxb.ZPath; //导入依赖的package包/类
@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));
}
开发者ID:didichuxing2,项目名称:https-github.com-apache-zookeeper,代码行数:24,代码来源:RootTest.java
示例4: testCreate
import org.apache.zookeeper.server.jersey.jaxb.ZPath; //导入依赖的package包/类
@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));
}
开发者ID:prodigeni,项目名称:zookeeper.dsc,代码行数:26,代码来源:RootTest.java
示例5: data
import org.apache.zookeeper.server.jersey.jaxb.ZPath; //导入依赖的package包/类
@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 }
});
}
开发者ID:maoling,项目名称:fuck_zookeeper,代码行数:37,代码来源:CreateTest.java
示例6: CreateTest
import org.apache.zookeeper.server.jersey.jaxb.ZPath; //导入依赖的package包/类
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;
}
开发者ID:maoling,项目名称:fuck_zookeeper,代码行数:14,代码来源:CreateTest.java
注:本文中的org.apache.zookeeper.server.jersey.jaxb.ZPath类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论