com.hazelcast.instance.Node.shutdown()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(7.3k)|赞(0)|评价(0)|浏览(121)

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

Node.shutdown介绍

暂无

代码示例

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

public void run() {
    node.shutdown(false);
  }
};

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

public void run() {
    node.shutdown(false);
  }
};

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

public static void tryShutdown(HazelcastInstance hazelcastInstance) {
    if (hazelcastInstance == null) {
      return;
    }
    HazelcastInstanceImpl factory = (HazelcastInstanceImpl) hazelcastInstance;
    closeSockets(factory);
    try {
      factory.node.shutdown(true);
    } catch (Throwable ignored) {
      ignore(ignored);
    }
  }
}

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

public static void tryShutdown(HazelcastInstance hazelcastInstance) {
    if (hazelcastInstance == null) {
      return;
    }
    HazelcastInstanceImpl factory = (HazelcastInstanceImpl) hazelcastInstance;
    closeSockets(factory);
    try {
      factory.node.shutdown(true);
    } catch (Throwable ignored) {
      ignore(ignored);
    }
  }
}

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

/**
   * Shutdowns a node by firing lifecycle events. Do not call this method for every node shutdown scenario
   * since {@link com.hazelcast.core.LifecycleListener}s will end up more than one
   * {@link com.hazelcast.core.LifecycleEvent.LifecycleState#SHUTTING_DOWN}
   * or {@link com.hazelcast.core.LifecycleEvent.LifecycleState#SHUTDOWN} events.
   *
   * @param node      Node to shutdown.
   * @param terminate <code>false</code> for graceful shutdown, <code>true</code> for terminate (un-graceful shutdown)
   */
  public static void shutdownNodeByFiringEvents(Node node, boolean terminate) {
    final HazelcastInstanceImpl hazelcastInstance = node.hazelcastInstance;
    final LifecycleServiceImpl lifecycleService = hazelcastInstance.getLifecycleService();
    lifecycleService.fireLifecycleEvent(LifecycleEvent.LifecycleState.SHUTTING_DOWN);
    node.shutdown(terminate);
    lifecycleService.fireLifecycleEvent(LifecycleEvent.LifecycleState.SHUTDOWN);
  }
}

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

/**
   * Shutdowns a node by firing lifecycle events. Do not call this method for every node shutdown scenario
   * since {@link com.hazelcast.core.LifecycleListener}s will end up more than one
   * {@link com.hazelcast.core.LifecycleEvent.LifecycleState#SHUTTING_DOWN}
   * or {@link com.hazelcast.core.LifecycleEvent.LifecycleState#SHUTDOWN} events.
   *
   * @param node      Node to shutdown.
   * @param terminate <code>false</code> for graceful shutdown, <code>true</code> for terminate (un-graceful shutdown)
   */
  public static void shutdownNodeByFiringEvents(Node node, boolean terminate) {
    final HazelcastInstanceImpl hazelcastInstance = node.hazelcastInstance;
    final LifecycleServiceImpl lifecycleService = hazelcastInstance.getLifecycleService();
    lifecycleService.fireLifecycleEvent(LifecycleEvent.LifecycleState.SHUTTING_DOWN);
    node.shutdown(terminate);
    lifecycleService.fireLifecycleEvent(LifecycleEvent.LifecycleState.SHUTDOWN);
  }
}

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

@Override
public void run() {
  final NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  final Node node = nodeEngine.getNode();
  final ILogger logger = nodeEngine.getLogger("com.hazelcast.security");
  logger.severe("Node could not join cluster. Authentication failed on master node! Node is going to shutdown now!");
  node.shutdown(true);
}

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

@Override
public void run() {
  NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  Node node = nodeEngine.getNode();
  ILogger logger = nodeEngine.getLogger("com.hazelcast.cluster");
  logger.severe("Node could not join cluster. A Configuration mismatch was detected: "
      + msg + " Node is going to shutdown now!");
  node.shutdown(true);
}

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

@Override
public void run() {
  final NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  final Node node = nodeEngine.getNode();
  final ILogger logger = nodeEngine.getLogger("com.hazelcast.security");
  logger.severe("Node could not join cluster. Authentication failed on master node! Node is going to shutdown now!");
  node.shutdown(true);
}

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

@Override
public void run() {
  NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  Node node = nodeEngine.getNode();
  ILogger logger = nodeEngine.getLogger("com.hazelcast.cluster");
  logger.severe("Node could not join cluster. A Configuration mismatch was detected: "
      + msg + " Node is going to shutdown now!");
  node.shutdown(true);
}

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

private void shutdown(boolean terminate) {
  synchronized (lifecycleLock) {
    fireLifecycleEvent(SHUTTING_DOWN);
    ManagementService managementService = instance.managementService;
    if (managementService != null) {
      managementService.destroy();
    }
    final Node node = instance.node;
    if (node != null) {
      node.shutdown(terminate);
    }
    HazelcastInstanceFactory.remove(instance);
    fireLifecycleEvent(SHUTDOWN);
  }
}

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

private void shutdown(boolean terminate) {
  synchronized (lifecycleLock) {
    fireLifecycleEvent(SHUTTING_DOWN);
    ManagementService managementService = instance.managementService;
    if (managementService != null) {
      managementService.destroy();
    }
    final Node node = instance.node;
    if (node != null) {
      node.shutdown(terminate);
    }
    HazelcastInstanceFactory.remove(instance);
    fireLifecycleEvent(SHUTDOWN);
  }
}

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

private void checkDeserializationFailure(ClusterServiceImpl clusterService) {
  if (deserializationFailure != null) {
    getLogger().severe("Node could not join cluster.", deserializationFailure);
    Node node = clusterService.getNodeEngine().getNode();
    node.shutdown(true);
    throw ExceptionUtil.rethrow(deserializationFailure);
  }
}

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

private void checkDeserializationFailure(ClusterServiceImpl clusterService) {
  if (deserializationFailure != null) {
    getLogger().severe("Node could not join cluster.", deserializationFailure);
    Node node = clusterService.getNodeEngine().getNode();
    node.shutdown(true);
    throw ExceptionUtil.rethrow(deserializationFailure);
  }
}

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

@Override
public void run() {
  final NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  final Node node = nodeEngine.getNode();
  if (node.getClusterService().isJoined()) {
    throw new IllegalStateException("Node is already joined but received a termination message! "
      + "Reason: " + failReasonMsg);
  }
  final ILogger logger = nodeEngine.getLogger("com.hazelcast.security");
  logger.severe("Node could not join cluster. Before join check failed node is going to shutdown now!");
  logger.severe("Reason of failure for node join: " + failReasonMsg);
  node.shutdown(true);
}

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

@Override
public void run() {
  final NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  final Node node = nodeEngine.getNode();
  if (node.getClusterService().isJoined()) {
    throw new IllegalStateException("Node is already joined but received a termination message! "
      + "Reason: " + failReasonMsg);
  }
  final ILogger logger = nodeEngine.getLogger("com.hazelcast.security");
  logger.severe("Node could not join cluster. Before join check failed node is going to shutdown now!");
  logger.severe("Reason of failure for node join: " + failReasonMsg);
  node.shutdown(true);
}

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

try {
  node.shutdown(true);
} catch (Throwable ignored) {
  ignore(ignored);

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

try {
  node.shutdown(true);
} catch (Throwable ignored) {
  ignore(ignored);

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

node.shutdown(true);
return false;

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

node.shutdown(true);
return false;

相关文章

微信公众号

最新文章

更多