本文整理了Java中com.hazelcast.instance.Node.shutdown()
方法的一些代码示例,展示了Node.shutdown()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Node.shutdown()
方法的具体详情如下:
包路径:com.hazelcast.instance.Node
类名称: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;
内容来源于网络,如有侵权,请联系作者删除!