本文整理了Java中org.jgroups.util.Util.generateLocalName()
方法的一些代码示例,展示了Util.generateLocalName()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Util.generateLocalName()
方法的具体详情如下:
包路径:org.jgroups.util.Util
类名称:Util
方法名:generateLocalName
暂无
代码示例来源:origin: wildfly/wildfly
public static Address createRandomAddress() {
return createRandomAddress(generateLocalName());
}
代码示例来源:origin: wildfly/wildfly
/**
* Generates and sets local_addr. Sends down a REMOVE_ADDRESS (if existing address was present) and
* a SET_LOCAL_ADDRESS
*/
protected JChannel setAddress() {
Address old_addr=local_addr;
local_addr=generateAddress();
if(old_addr != null)
down(new Event(Event.REMOVE_ADDRESS, old_addr));
if(name == null || name.isEmpty()) // generate a logical name if not set
name=Util.generateLocalName();
if(name != null && !name.isEmpty())
NameCache.add(local_addr, name);
Event evt=new Event(Event.SET_LOCAL_ADDRESS, local_addr);
down(evt);
if(up_handler != null)
up_handler.up(evt);
return this;
}
代码示例来源:origin: org.jboss.eap/wildfly-client-all
public static Address createRandomAddress() {
return createRandomAddress(generateLocalName());
}
代码示例来源:origin: org.jboss.eap/wildfly-client-all
/**
* Generates and sets local_addr. Sends down a REMOVE_ADDRESS (if existing address was present) and
* a SET_LOCAL_ADDRESS
*/
protected JChannel setAddress() {
Address old_addr=local_addr;
local_addr=generateAddress();
if(old_addr != null)
down(new Event(Event.REMOVE_ADDRESS, old_addr));
if(name == null || name.isEmpty()) // generate a logical name if not set
name=Util.generateLocalName();
if(name != null && !name.isEmpty())
NameCache.add(local_addr, name);
Event evt=new Event(Event.SET_LOCAL_ADDRESS, local_addr);
down(evt);
if(up_handler != null)
up_handler.up(evt);
return this;
}
代码示例来源:origin: com.thinkbiganalytics.kylo/kylo-cluster-manager-core
/**
* Start a channel on the cluster
*/
@Override
public void start() throws Exception {
if (channel != null) {
log.info("Kylo cluster has already been started");
} else if (StringUtils.isNotBlank(jgroupsConfigFile)) {
try {
channel = new JChannel(jgroupsConfigFile);
String name = Util.generateLocalName();
channel.setName(name);
channel.setReceiver(this);
channel.addChannelListener(new Listener());
channel.enableStats(true);
// do this before connecting, once connected messages may be in flight and methods in clusterSummary will be called
clusterNodeSummary = new DefaultClusterNodeSummary(channel.getAddressAsString());
channel.connect(CLUSTER_NAME);
clusterNodeSummary.connected();
} catch (FileNotFoundException e) {
log.error("Unable to find the jgroups cluster configuration file {}. Kylo is not clustered ", jgroupsConfigFile);
}
}
}
内容来源于网络,如有侵权,请联系作者删除!