本文整理了Java中com.twitter.finagle.common.zookeeper.ZooKeeperClient.registerExpirationHandler()
方法的一些代码示例,展示了ZooKeeperClient.registerExpirationHandler()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperClient.registerExpirationHandler()
方法的具体详情如下:
包路径:com.twitter.finagle.common.zookeeper.ZooKeeperClient
类名称:ZooKeeperClient
方法名:registerExpirationHandler
[英]Clients that need to re-establish state after session expiration can register an onExpired command to execute.
[中]需要在会话过期后重新建立状态的客户端可以注册一个onExpired命令来执行。
代码示例来源:origin: com.twitter/finagle-serversets
synchronized void setMembers(Iterable<String> members) {
if (stopped) {
LOG.info("Suppressing membership update, no longer watching " + this);
return;
}
if (this.members == null) {
// Reset our watch on the group if session expires - only needs to be registered once.
zkClient.registerExpirationHandler(new Runnable() {
@Override public void run() {
tryWatchGroup();
}
});
}
Set<String> membership = new HashSet<>();
members.iterator().forEachRemaining(membership::add);
if (!membership.equals(this.members)) {
groupChangeListener.onGroupChange(members);
this.members = Collections.unmodifiableSet(membership);
}
}
}
代码示例来源:origin: com.twitter/finagle-serversets_2.11
synchronized void setMembers(Iterable<String> members) {
if (stopped) {
LOG.info("Suppressing membership update, no longer watching " + this);
return;
}
if (this.members == null) {
// Reset our watch on the group if session expires - only needs to be registered once.
zkClient.registerExpirationHandler(new Runnable() {
@Override public void run() {
tryWatchGroup();
}
});
}
Set<String> membership = new HashSet<>();
members.iterator().forEachRemaining(membership::add);
if (!membership.equals(this.members)) {
groupChangeListener.onGroupChange(members);
this.members = Collections.unmodifiableSet(membership);
}
}
}
代码示例来源:origin: com.twitter/finagle-serversets_2.11
zkClient.registerExpirationHandler(new Runnable() {
@Override public void run() {
tryJoin();
代码示例来源:origin: com.twitter/finagle-serversets
zkClient.registerExpirationHandler(new Runnable() {
@Override public void run() {
tryJoin();
代码示例来源:origin: com.twitter/finagle-serversets_2.11
public Runnable watch() throws WatchException, InterruptedException {
Watcher onExpirationWatcher = zkClient.registerExpirationHandler(new Runnable() {
@Override public void run() {
// Servers may have changed Status while we were disconnected from ZooKeeper, check and
// re-register our node watches.
rebuildServerSet();
}
});
try {
return group.watch(new GroupChangeListener() {
@Override public void onGroupChange(Iterable<String> memberIds) {
notifyGroupChange(memberIds);
}
});
} catch (WatchException e) {
zkClient.unregister(onExpirationWatcher);
throw e;
} catch (InterruptedException e) {
zkClient.unregister(onExpirationWatcher);
throw e;
}
}
代码示例来源:origin: com.twitter/finagle-serversets
public Runnable watch() throws WatchException, InterruptedException {
Watcher onExpirationWatcher = zkClient.registerExpirationHandler(new Runnable() {
@Override public void run() {
// Servers may have changed Status while we were disconnected from ZooKeeper, check and
// re-register our node watches.
rebuildServerSet();
}
});
try {
return group.watch(new GroupChangeListener() {
@Override public void onGroupChange(Iterable<String> memberIds) {
notifyGroupChange(memberIds);
}
});
} catch (WatchException e) {
zkClient.unregister(onExpirationWatcher);
throw e;
} catch (InterruptedException e) {
zkClient.unregister(onExpirationWatcher);
throw e;
}
}
内容来源于网络,如有侵权,请联系作者删除!