本文整理了Java中com.hazelcast.instance.Node.getThisUuid()方法的一些代码示例，展示了Node.getThisUuid()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Node.getThisUuid()方法的具体详情如下：
包路径：com.hazelcast.instance.Node
类名称：Node
方法名：getThisUuid

Node.getThisUuid介绍

暂无

代码示例

代码示例来源：origin: com.hazelcast/hazelcast-all

@Override
public String getThisUuid() {
  return node.getThisUuid();
}

代码示例来源：origin: hazelcast/hazelcast-jet

@Override
public String getThisUuid() {
  return node.getThisUuid();
}

代码示例来源：origin: com.hazelcast/hazelcast-all

private void doInvokeLocal(boolean isAsync) {
  if (op.getCallerUuid() == null) {
    op.setCallerUuid(context.node.getThisUuid());
  }
  responseReceived = FALSE;
  op.setOperationResponseHandler(this);
  if (isAsync) {
    context.operationExecutor.execute(op);
  } else {
    context.operationExecutor.runOrExecute(op);
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet

private boolean isMemberExcludedFromHotRestart() {
  final NodeExtension nodeExtension = node.getNodeExtension();
  return !nodeExtension.isStartCompleted()
      && nodeExtension.getInternalHotRestartService().isMemberExcluded(node.getThisAddress(), node.getThisUuid());
}

代码示例来源：origin: com.hazelcast/hazelcast-all

private boolean shouldResetHotRestartData() {
  final NodeExtension nodeExtension = node.getNodeExtension();
  return !nodeExtension.isStartCompleted()
      && nodeExtension.getInternalHotRestartService().isMemberExcluded(node.getThisAddress(), node.getThisUuid());
}

代码示例来源：origin: hazelcast/hazelcast-jet

private void doInvokeLocal(boolean isAsync) {
  if (op.getCallerUuid() == null) {
    op.setCallerUuid(context.node.getThisUuid());
  }
  responseReceived = FALSE;
  op.setOperationResponseHandler(this);
  if (isAsync) {
    context.operationExecutor.execute(op);
  } else {
    context.operationExecutor.runOrExecute(op);
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet

/**
 * Completes the job which is coordinated with the given master context object.
 */
void completeJob(MasterContext masterContext, long completionTime, Throwable error) {
  // the order of operations is important.
  long jobId = masterContext.jobId();
  String coordinator = nodeEngine.getNode().getThisUuid();
  jobRepository.completeJob(jobId, coordinator, completionTime, error);
  if (masterContexts.remove(masterContext.jobId(), masterContext)) {
    logger.fine(masterContext.jobIdString() + " is completed");
  } else {
    MasterContext existing = masterContexts.get(jobId);
    if (existing != null) {
      logger.severe("Different master context found to complete " + masterContext.jobIdString()
          + ", master context execution " + idToString(existing.executionId()));
    } else {
      logger.severe("No master context found to complete " + masterContext.jobIdString());
    }
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet

String localMemberUuid = node.getThisUuid();
final String clientUuid = endpoint.getUuid();
String ownerUuid = ownershipMappings.get(clientUuid);

代码示例来源：origin: com.hazelcast/hazelcast-all

String localMemberUuid = node.getThisUuid();
final String clientUuid = endpoint.getUuid();
String ownerUuid = ownershipMappings.get(clientUuid);

代码示例来源：origin: com.hazelcast/hazelcast-all

public PhoneHomeParameterCreator createParameters(Node hazelcastNode) {
  ClusterServiceImpl clusterService = hazelcastNode.getClusterService();
  int clusterSize = clusterService.getMembers().size();
  Long clusterUpTime = clusterService.getClusterClock().getClusterUpTime();
  RuntimeMXBean runtimeMxBean = ManagementFactory.getRuntimeMXBean();
  JetBuildInfo jetBuildInfo = hazelcastNode.getBuildInfo().getJetBuildInfo();
  PhoneHomeParameterCreator parameterCreator = new PhoneHomeParameterCreator()
      .addParam("version", buildInfo.getVersion())
      .addParam("m", hazelcastNode.getThisUuid())
      .addParam("p", getDownloadId())
      .addParam("c", clusterService.getClusterId())
      .addParam("crsz", convertToLetter(clusterSize))
      .addParam("cssz", convertToLetter(hazelcastNode.clientEngine.getClientEndpointCount()))
      .addParam("cuptm", Long.toString(clusterUpTime))
      .addParam("nuptm", Long.toString(runtimeMxBean.getUptime()))
      .addParam("jvmn", runtimeMxBean.getVmName())
      .addParam("jvmv", System.getProperty("java.version"))
      .addParam("jetv", jetBuildInfo == null ? "" : jetBuildInfo.getVersion());
  addClientInfo(hazelcastNode, parameterCreator);
  addOSInfo(parameterCreator);
  boolean isManagementCenterConfigEnabled = hazelcastNode.config.getManagementCenterConfig().isEnabled();
  if (isManagementCenterConfigEnabled) {
    addManCenterInfo(hazelcastNode, clusterSize, parameterCreator);
  } else {
    parameterCreator.addParam("mclicense", "MC_NOT_CONFIGURED");
    parameterCreator.addParam("mcver", "MC_NOT_CONFIGURED");
  }
  return parameterCreator;
}

代码示例来源：origin: hazelcast/hazelcast-jet

public PhoneHomeParameterCreator createParameters(Node hazelcastNode) {
  ClusterServiceImpl clusterService = hazelcastNode.getClusterService();
  int clusterSize = clusterService.getMembers().size();
  Long clusterUpTime = clusterService.getClusterClock().getClusterUpTime();
  RuntimeMXBean runtimeMxBean = ManagementFactory.getRuntimeMXBean();
  JetBuildInfo jetBuildInfo = hazelcastNode.getBuildInfo().getJetBuildInfo();
  PhoneHomeParameterCreator parameterCreator = new PhoneHomeParameterCreator()
      .addParam("version", buildInfo.getVersion())
      .addParam("m", hazelcastNode.getThisUuid())
      .addParam("p", getDownloadId())
      .addParam("c", clusterService.getClusterId())
      .addParam("crsz", convertToLetter(clusterSize))
      .addParam("cssz", convertToLetter(hazelcastNode.clientEngine.getClientEndpointCount()))
      .addParam("cuptm", Long.toString(clusterUpTime))
      .addParam("nuptm", Long.toString(runtimeMxBean.getUptime()))
      .addParam("jvmn", runtimeMxBean.getVmName())
      .addParam("jvmv", System.getProperty("java.version"))
      .addParam("jetv", jetBuildInfo == null ? "" : jetBuildInfo.getVersion());
  addClientInfo(hazelcastNode, parameterCreator);
  addOSInfo(parameterCreator);
  boolean isManagementCenterConfigEnabled = hazelcastNode.config.getManagementCenterConfig().isEnabled();
  if (isManagementCenterConfigEnabled) {
    addManCenterInfo(hazelcastNode, clusterSize, parameterCreator);
  } else {
    parameterCreator.addParam("mclicense", "MC_NOT_CONFIGURED");
    parameterCreator.addParam("mcver", "MC_NOT_CONFIGURED");
  }
  return parameterCreator;
}

代码示例来源：origin: hazelcast/hazelcast-jet

private void handleActiveAndJoined(JoinMessage joinMessage) {
  if (!(joinMessage instanceof JoinRequest)) {
    logDroppedMessage(joinMessage);
    return;
  }
  ClusterServiceImpl clusterService = node.getClusterService();
  Address masterAddress = clusterService.getMasterAddress();
  if (clusterService.isMaster()) {
    JoinMessage response = new JoinMessage(Packet.VERSION, node.getBuildInfo().getBuildNumber(), node.getVersion(),
        node.getThisAddress(), node.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
    node.multicastService.send(response);
  } else if (joinMessage.getAddress().equals(masterAddress)) {
    MemberImpl master = node.getClusterService().getMember(masterAddress);
    if (master != null && !master.getUuid().equals(joinMessage.getUuid())) {
      String message = "New join request has been received from current master. Suspecting " + masterAddress;
      logger.warning(message);
      // I just make a local suspicion. Probably other nodes will eventually suspect as well.
      clusterService.suspectMember(master, message, false);
    }
  }
}

代码示例来源：origin: com.hazelcast/hazelcast-all

private void handleActiveAndJoined(JoinMessage joinMessage) {
  if (!(joinMessage instanceof JoinRequest)) {
    logDroppedMessage(joinMessage);
    return;
  }
  ClusterServiceImpl clusterService = node.getClusterService();
  Address masterAddress = clusterService.getMasterAddress();
  if (clusterService.isMaster()) {
    JoinMessage response = new JoinMessage(Packet.VERSION, node.getBuildInfo().getBuildNumber(), node.getVersion(),
        node.getThisAddress(), node.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
    node.multicastService.send(response);
  } else if (joinMessage.getAddress().equals(masterAddress)) {
    MemberImpl master = node.getClusterService().getMember(masterAddress);
    if (master != null && !master.getUuid().equals(joinMessage.getUuid())) {
      String message = "New join request has been received from current master. Suspecting " + masterAddress;
      logger.warning(message);
      // I just make a local suspicion. Probably other nodes will eventually suspect as well.
      clusterService.suspectMember(master, message, false);
    }
  }
}