本文整理了Java中io.fabric8.groups.Group.isConnected()
方法的一些代码示例,展示了Group.isConnected()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Group.isConnected()
方法的具体详情如下:
包路径:io.fabric8.groups.Group
类名称:Group
方法名:isConnected
[英]Are we connected with the cluster?
[中]
代码示例来源:origin: io.fabric8/fabric-groups
@Override
public boolean isConnected() {
Group<T> group = this.group;
if (group != null) {
return group.isConnected();
} else {
return false;
}
}
代码示例来源:origin: jboss-fuse/fabric8
@Override
public boolean isConnected() {
Group<T> group = this.group;
if (group != null) {
return group.isConnected();
} else {
return false;
}
}
代码示例来源:origin: io.fabric8/fabric-camel
@Override
public void groupEvent(Group group, GroupEvent event) {
switch (event) {
case CONNECTED:
break;
case CHANGED:
if (singleton.isConnected()) {
if (singleton.isMaster()) {
if (LOG.isDebugEnabled()) {
LOG.debug("Master/Standby endpoint is Master for: " + endpoint + " in " + endpoint.getCamelContext());
}
onLockOwned();
} else {
if (LOG.isDebugEnabled()) {
LOG.debug("Master/Standby endpoint is Standby for: " + endpoint + " in " + endpoint.getCamelContext());
}
}
}
break;
case DISCONNECTED:
try {
stopConsumer();
} catch (Exception e) {
LOG.error("Failed to stop master consumer for: " + endpoint + ". Reason: " + e, e);
}
break;
}
}
代码示例来源:origin: jboss-fuse/fabric8
@Override
public void groupEvent(Group group, GroupEvent event) {
switch (event) {
case CONNECTED:
break;
case CHANGED:
if (singleton.isConnected()) {
if (singleton.isMaster()) {
if (LOG.isDebugEnabled()) {
LOG.debug("Master/Standby endpoint is Master for: " + endpoint + " in " + endpoint.getCamelContext());
}
onLockOwned();
} else {
if (LOG.isDebugEnabled()) {
LOG.debug("Master/Standby endpoint is Standby for: " + endpoint + " in " + endpoint.getCamelContext());
}
}
}
break;
case DISCONNECTED:
try {
stopConsumer();
} catch (Exception e) {
LOG.error("Failed to stop master consumer for: " + endpoint + ". Reason: " + e, e);
}
break;
}
}
内容来源于网络,如有侵权,请联系作者删除!