本文整理了Java中com.hazelcast.instance.Node.getJoiner()
方法的一些代码示例,展示了Node.getJoiner()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Node.getJoiner()
方法的具体详情如下:
包路径:com.hazelcast.instance.Node
类名称:Node
方法名:getJoiner
暂无
代码示例来源:origin: com.hazelcast/hazelcast-all
private void searchForOtherClusters() {
Joiner joiner = node.getJoiner();
if (joiner != null) {
joiner.searchForOtherClusters();
}
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
private void searchForOtherClusters() {
Joiner joiner = node.getJoiner();
if (joiner != null) {
joiner.searchForOtherClusters();
}
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public void onSuccessfulConnection(Address address) {
if (!node.getClusterService().isJoined()) {
node.getJoiner().unblacklist(address);
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
public void onSuccessfulConnection(Address address) {
if (!node.getClusterService().isJoined()) {
node.getJoiner().unblacklist(address);
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
public void merge(Address newTargetAddress) {
node.getJoiner().setTargetAddress(newTargetAddress);
LifecycleServiceImpl lifecycleService = node.hazelcastInstance.getLifecycleService();
lifecycleService.runUnderLifecycleLock(new ClusterMergeTask(node));
}
代码示例来源:origin: hazelcast/hazelcast-jet
public void merge(Address newTargetAddress) {
node.getJoiner().setTargetAddress(newTargetAddress);
LifecycleServiceImpl lifecycleService = node.hazelcastInstance.getLifecycleService();
lifecycleService.runUnderLifecycleLock(new ClusterMergeTask(node));
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public void onFailedConnection(final Address address) {
ClusterService clusterService = node.clusterService;
if (!clusterService.isJoined()) {
node.getJoiner().blacklist(address, false);
} else {
if (clusterService.getMember(address) != null) {
nodeEngine.getExecutionService().schedule(ExecutionService.IO_EXECUTOR, new ReconnectionTask(address),
getConnectionMonitorInterval(), TimeUnit.MILLISECONDS);
}
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
public void onFailedConnection(final Address address) {
ClusterService clusterService = node.clusterService;
if (!clusterService.isJoined()) {
node.getJoiner().blacklist(address, false);
} else {
if (clusterService.getMember(address) != null) {
nodeEngine.getExecutionService().schedule(ExecutionService.IO_EXECUTOR, new ReconnectionTask(address),
getConnectionMonitorInterval(), TimeUnit.MILLISECONDS);
}
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
private void handleNotActiveOrNotJoined(JoinMessage joinMessage) {
if (isJoinRequest(joinMessage)) {
Joiner joiner = node.getJoiner();
if (joiner instanceof MulticastJoiner) {
MulticastJoiner multicastJoiner = (MulticastJoiner) joiner;
multicastJoiner.onReceivedJoinRequest((JoinRequest) joinMessage);
} else {
logDroppedMessage(joinMessage);
}
} else {
Address address = joinMessage.getAddress();
if (node.getJoiner().isBlacklisted(address)) {
logDroppedMessage(joinMessage);
return;
}
ClusterServiceImpl clusterService = node.getClusterService();
if (!clusterService.isJoined() && clusterService.getMasterAddress() == null) {
clusterService.setMasterAddressToJoin(joinMessage.getAddress());
} else {
logDroppedMessage(joinMessage);
}
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
private void handleNotActiveOrNotJoined(JoinMessage joinMessage) {
if (isJoinRequest(joinMessage)) {
Joiner joiner = node.getJoiner();
if (joiner instanceof MulticastJoiner) {
MulticastJoiner multicastJoiner = (MulticastJoiner) joiner;
multicastJoiner.onReceivedJoinRequest((JoinRequest) joinMessage);
} else {
logDroppedMessage(joinMessage);
}
} else {
Address address = joinMessage.getAddress();
if (node.getJoiner().isBlacklisted(address)) {
logDroppedMessage(joinMessage);
return;
}
ClusterServiceImpl clusterService = node.getClusterService();
if (!clusterService.isJoined() && clusterService.getMasterAddress() == null) {
clusterService.setMasterAddressToJoin(joinMessage.getAddress());
} else {
logDroppedMessage(joinMessage);
}
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
public void run() {
final NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
Node node = nodeEngine.getNode();
Joiner joiner = node.getJoiner();
ClusterServiceImpl clusterService = node.getClusterService();
final ILogger logger = node.getLogger(getClass().getName());
if (joiner instanceof TcpIpJoiner) {
TcpIpJoiner tcpIpJoiner = (TcpIpJoiner) joiner;
final Address endpoint = getCallerAddress();
final Address masterAddress = clusterService.getMasterAddress();
approvedAsMaster = !tcpIpJoiner.isClaimingMaster() && !clusterService.isMaster()
&& (masterAddress == null || masterAddress.equals(endpoint));
} else {
approvedAsMaster = false;
logger.warning("This node requires MulticastJoin strategy!");
}
if (logger.isFineEnabled()) {
logger.fine("Sending '" + approvedAsMaster + "' for master claim of node: " + getCallerAddress());
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public void run() {
NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
Connection connection = getConnection();
String message = "Node could not join cluster at node: " + connection.getEndPoint()
+ " Cause: the target cluster has a different group-name";
connection.close(message, null);
ILogger logger = nodeEngine.getLogger("com.hazelcast.cluster");
logger.warning(message);
Node node = nodeEngine.getNode();
node.getJoiner().blacklist(getCallerAddress(), true);
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public void run() {
final NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
Node node = nodeEngine.getNode();
Joiner joiner = node.getJoiner();
ClusterServiceImpl clusterService = node.getClusterService();
final ILogger logger = node.getLogger(getClass().getName());
if (joiner instanceof TcpIpJoiner) {
TcpIpJoiner tcpIpJoiner = (TcpIpJoiner) joiner;
final Address endpoint = getCallerAddress();
final Address masterAddress = clusterService.getMasterAddress();
approvedAsMaster = !tcpIpJoiner.isClaimingMastership() && !clusterService.isMaster()
&& (masterAddress == null || masterAddress.equals(endpoint));
} else {
approvedAsMaster = false;
logger.warning("This node requires MulticastJoin strategy!");
}
if (logger.isFineEnabled()) {
logger.fine("Sending '" + approvedAsMaster + "' for master claim of node: " + getCallerAddress());
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
public void run() {
NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
Connection connection = getConnection();
String message = "Node could not join cluster at node: " + connection.getEndPoint()
+ " Cause: the target cluster has a different group-name";
connection.close(message, null);
ILogger logger = nodeEngine.getLogger("com.hazelcast.cluster");
logger.warning(message);
Node node = nodeEngine.getNode();
node.getJoiner().blacklist(getCallerAddress(), true);
}
内容来源于网络,如有侵权,请联系作者删除!