本文整理汇总了Java中org.apache.zookeeper.server.jersey.jaxb.ZSession类的典型用法代码示例。如果您正苦于以下问题：Java ZSession类的具体用法？Java ZSession怎么用？Java ZSession使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ZSession类属于org.apache.zookeeper.server.jersey.jaxb包，在下文中一共展示了ZSession类的12个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testSendHeartbeat
import org.apache.zookeeper.server.jersey.jaxb.ZSession; //导入依赖的package包/类
@Test
public void testSendHeartbeat() throws InterruptedException {
ZSession session = createSession("2");
Thread.sleep(1000);
WebResource wr = sessionsr.path(session.id);
Builder b = wr.accept(MediaType.APPLICATION_JSON);
ClientResponse cr = b.put(ClientResponse.class, null);
assertEquals(ClientResponse.Status.OK, cr.getClientResponseStatus());
Thread.sleep(1500);
assertTrue(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
Thread.sleep(1000);
assertFalse(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
}
开发者ID:maoling，项目名称:fuck_zookeeper，代码行数:18，代码来源:SessionTest.java
示例2: testCreateEphemeralZNode
import org.apache.zookeeper.server.jersey.jaxb.ZSession; //导入依赖的package包/类
@Test
public void testCreateEphemeralZNode()
throws KeeperException, InterruptedException, IOException {
ZSession session = createSession("30");
WebResource wr = znodesr.path("/")
.queryParam("op", "create")
.queryParam("name", "ephemeral-test")
.queryParam("ephemeral", "true")
.queryParam("session", session.id)
.queryParam("null", "true");
Builder b = wr.accept(MediaType.APPLICATION_JSON);
ClientResponse cr = b.post(ClientResponse.class);
assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());
Stat stat = new Stat();
zk.getData("/ephemeral-test", false, stat);
ZooKeeper sessionZK = ZooKeeperService.getClient(CONTEXT_PATH, session.id);
assertEquals(stat.getEphemeralOwner(), sessionZK.getSessionId());
}
开发者ID:maoling，项目名称:fuck_zookeeper，代码行数:23，代码来源:SessionTest.java
示例3: testSendHeartbeat
import org.apache.zookeeper.server.jersey.jaxb.ZSession; //导入依赖的package包/类
@Test
public void testSendHeartbeat() throws InterruptedException {
ZSession session = createSession("2");
Thread.sleep(1000);
WebResource wr = sessionsr.path(session.id);
Builder b = wr.accept(MediaType.APPLICATION_JSON);
ClientResponse cr = b.put(ClientResponse.class, null);
Assert.assertEquals(ClientResponse.Status.OK, cr.getClientResponseStatus());
Thread.sleep(1500);
Assert.assertTrue(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
Thread.sleep(1000);
Assert.assertFalse(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
}
开发者ID:didichuxing2，项目名称:https-github.com-apache-zookeeper，代码行数:18，代码来源:SessionTest.java
示例4: testCreateEphemeralZNode
import org.apache.zookeeper.server.jersey.jaxb.ZSession; //导入依赖的package包/类
@Test
public void testCreateEphemeralZNode()
throws KeeperException, InterruptedException, IOException {
ZSession session = createSession("30");
WebResource wr = znodesr.path("/")
.queryParam("op", "create")
.queryParam("name", "ephemeral-test")
.queryParam("ephemeral", "true")
.queryParam("session", session.id)
.queryParam("null", "true");
Builder b = wr.accept(MediaType.APPLICATION_JSON);
ClientResponse cr = b.post(ClientResponse.class);
Assert.assertEquals(ClientResponse.Status.CREATED, cr.getClientResponseStatus());
Stat stat = new Stat();
zk.getData("/ephemeral-test", false, stat);
ZooKeeper sessionZK = ZooKeeperService.getClient(CONTEXT_PATH, session.id);
Assert.assertEquals(stat.getEphemeralOwner(), sessionZK.getSessionId());
}
开发者ID:didichuxing2，项目名称:https-github.com-apache-zookeeper，代码行数:23，代码来源:SessionTest.java
示例5: createSession
import org.apache.zookeeper.server.jersey.jaxb.ZSession; //导入依赖的package包/类
private ZSession createSession(String expire) {
WebResource wr = sessionsr.queryParam("op", "create")
.queryParam("expire", expire);
Builder b = wr.accept(MediaType.APPLICATION_JSON);
ClientResponse cr = b.post(ClientResponse.class, null);
assertEquals(ClientResponse.Status.CREATED, cr
.getClientResponseStatus());
return cr.getEntity(ZSession.class);
}
开发者ID:maoling，项目名称:fuck_zookeeper，代码行数:12，代码来源:SessionTest.java
示例6: testCreateNewSession
import org.apache.zookeeper.server.jersey.jaxb.ZSession; //导入依赖的package包/类
@Test
public void testCreateNewSession() throws JSONException {
ZSession session = createSession();
assertEquals(session.id.length(), 36);
// use out-of-band method to verify
assertTrue(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
}
开发者ID:maoling，项目名称:fuck_zookeeper，代码行数:9，代码来源:SessionTest.java
示例7: testSessionExpires
import org.apache.zookeeper.server.jersey.jaxb.ZSession; //导入依赖的package包/类
@Test
public void testSessionExpires() throws InterruptedException {
ZSession session = createSession("1");
// use out-of-band method to verify
assertTrue(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
// wait for the session to be closed
Thread.sleep(1500);
assertFalse(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
}
开发者ID:maoling，项目名称:fuck_zookeeper，代码行数:12，代码来源:SessionTest.java
示例8: testDeleteSession
import org.apache.zookeeper.server.jersey.jaxb.ZSession; //导入依赖的package包/类
@Test
public void testDeleteSession() {
ZSession session = createSession("30");
WebResource wr = sessionsr.path(session.id);
Builder b = wr.accept(MediaType.APPLICATION_JSON);
assertTrue(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
ClientResponse cr = b.delete(ClientResponse.class, null);
assertEquals(ClientResponse.Status.NO_CONTENT,
cr.getClientResponseStatus());
assertFalse(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
}
开发者ID:maoling，项目名称:fuck_zookeeper，代码行数:15，代码来源:SessionTest.java
示例9: createSession
import org.apache.zookeeper.server.jersey.jaxb.ZSession; //导入依赖的package包/类
private ZSession createSession(String expire) {
WebResource wr = sessionsr.queryParam("op", "create")
.queryParam("expire", expire);
Builder b = wr.accept(MediaType.APPLICATION_JSON);
ClientResponse cr = b.post(ClientResponse.class, null);
Assert.assertEquals(ClientResponse.Status.CREATED, cr
.getClientResponseStatus());
return cr.getEntity(ZSession.class);
}
开发者ID:didichuxing2，项目名称:https-github.com-apache-zookeeper，代码行数:12，代码来源:SessionTest.java
示例10: testCreateNewSession
import org.apache.zookeeper.server.jersey.jaxb.ZSession; //导入依赖的package包/类
@Test
public void testCreateNewSession() throws JSONException {
ZSession session = createSession();
Assert.assertEquals(session.id.length(), 36);
// use out-of-band method to verify
Assert.assertTrue(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
}
开发者ID:didichuxing2，项目名称:https-github.com-apache-zookeeper，代码行数:9，代码来源:SessionTest.java
示例11: testSessionExpires
import org.apache.zookeeper.server.jersey.jaxb.ZSession; //导入依赖的package包/类
@Test
public void testSessionExpires() throws InterruptedException {
ZSession session = createSession("1");
// use out-of-band method to verify
Assert.assertTrue(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
// wait for the session to be closed
Thread.sleep(1500);
Assert.assertFalse(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
}
开发者ID:didichuxing2，项目名称:https-github.com-apache-zookeeper，代码行数:12，代码来源:SessionTest.java
示例12: testDeleteSession
import org.apache.zookeeper.server.jersey.jaxb.ZSession; //导入依赖的package包/类
@Test
public void testDeleteSession() {
ZSession session = createSession("30");
WebResource wr = sessionsr.path(session.id);
Builder b = wr.accept(MediaType.APPLICATION_JSON);
Assert.assertTrue(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
ClientResponse cr = b.delete(ClientResponse.class, null);
Assert.assertEquals(ClientResponse.Status.NO_CONTENT,
cr.getClientResponseStatus());
Assert.assertFalse(ZooKeeperService.isConnected(CONTEXT_PATH, session.id));
}
开发者ID:didichuxing2，项目名称:https-github.com-apache-zookeeper，代码行数:15，代码来源:SessionTest.java
注：本文中的org.apache.zookeeper.server.jersey.jaxb.ZSession类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论