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

Node.getNodeEngine介绍

暂无

代码示例

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

JetInstanceImpl(HazelcastInstanceImpl hazelcastInstance, JetConfig config) {
  super(hazelcastInstance);
  this.nodeEngine = hazelcastInstance.node.getNodeEngine();
  this.config = config;
}

代码示例来源：origin: noctarius/snowcast

@Nonnull
  private NodeEngine getNodeEngine(@Nonnull HazelcastInstance hazelcastInstance) {
    return ExceptionUtils.execute(() -> {
      // Ugly hack due to lack in SPI
      //ACCESSIBILITY_HACK
      Field originalField = HazelcastInstanceProxy.class.getDeclaredField("original");
      originalField.setAccessible(true);
      HazelcastInstanceImpl impl = (HazelcastInstanceImpl) originalField.get(hazelcastInstance);
      return impl.node.getNodeEngine();
    }, RETRIEVE_NODE_ENGINE_FAILED);
  }
}

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

@Override
public Collection<DistributedObject> getDistributedObjects() {
  ProxyService proxyService = node.getNodeEngine().getProxyService();
  return proxyService.getAllDistributedObjects();
}

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

@Override
public <T> T executeTransaction(TransactionOptions options, TransactionalTask<T> task)
    throws TransactionException {
  TransactionManagerService transactionManagerService = node.getNodeEngine().getTransactionManagerService();
  return transactionManagerService.executeTransaction(options, task);
}

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

private <T> T createMapService() {
  ConstructorFunction<NodeEngine, MapService> constructor = getDefaultMapServiceConstructor();
  NodeEngineImpl nodeEngine = node.getNodeEngine();
  return (T) constructor.createNew(nodeEngine);
}

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

@Override
public String addDistributedObjectListener(DistributedObjectListener distributedObjectListener) {
  final ProxyService proxyService = node.getNodeEngine().getProxyService();
  return proxyService.addProxyListener(distributedObjectListener);
}

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

@Override
public boolean removeDistributedObjectListener(String registrationId) {
  final ProxyService proxyService = node.getNodeEngine().getProxyService();
  return proxyService.removeProxyListener(registrationId);
}

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

@Override
public boolean removeDistributedObjectListener(String registrationId) {
  final ProxyService proxyService = node.getNodeEngine().getProxyService();
  return proxyService.removeProxyListener(registrationId);
}

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

@Override
public TransactionContext newTransactionContext(TransactionOptions options) {
  TransactionManagerService transactionManagerService = node.getNodeEngine().getTransactionManagerService();
  return transactionManagerService.newTransactionContext(options);
}

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

@Override
@SuppressWarnings("unchecked")
public <T extends DistributedObject> T getDistributedObject(String serviceName, String name) {
  ProxyService proxyService = node.getNodeEngine().getProxyService();
  return (T) proxyService.getDistributedObject(serviceName, name);
}

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

@Override
public Collection<DistributedObject> getDistributedObjects() {
  ProxyService proxyService = node.getNodeEngine().getProxyService();
  return proxyService.getAllDistributedObjects();
}

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

@Override
@SuppressWarnings("unchecked")
public <T extends DistributedObject> T getDistributedObject(String serviceName, String name) {
  ProxyService proxyService = node.getNodeEngine().getProxyService();
  return (T) proxyService.getDistributedObject(serviceName, name);
}

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

private <T> T createMapService() {
  ConstructorFunction<NodeEngine, MapService> constructor = getDefaultMapServiceConstructor();
  NodeEngineImpl nodeEngine = node.getNodeEngine();
  return (T) constructor.createNew(nodeEngine);
}

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

PartitionReplicaStateChecker(Node node, InternalPartitionServiceImpl partitionService) {
  this.node = node;
  this.nodeEngine = node.getNodeEngine();
  this.partitionService = partitionService;
  this.logger = node.getLogger(getClass());
  this.partitionStateManager = partitionService.getPartitionStateManager();
  this.migrationManager = partitionService.getMigrationManager();
}

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

PartitionReplicaStateChecker(Node node, InternalPartitionServiceImpl partitionService) {
  this.node = node;
  this.nodeEngine = node.getNodeEngine();
  this.partitionService = partitionService;
  this.logger = node.getLogger(getClass());
  this.partitionStateManager = partitionService.getPartitionStateManager();
  this.migrationManager = partitionService.getMigrationManager();
}

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

@Override
public void onClusterStateChange(ClusterState newState, boolean isTransient) {
  ServiceManager serviceManager = node.getNodeEngine().getServiceManager();
  List<ClusterStateListener> listeners = serviceManager.getServices(ClusterStateListener.class);
  for (ClusterStateListener listener : listeners) {
    listener.onClusterStateChange(newState);
  }
}

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

MembershipManager(Node node, ClusterServiceImpl clusterService, Lock clusterServiceLock) {
  this.node = node;
  this.clusterService = clusterService;
  this.clusterServiceLock = clusterServiceLock;
  this.nodeEngine = node.getNodeEngine();
  this.logger = node.getLogger(getClass());
  mastershipClaimTimeoutSeconds = node.getProperties().getInteger(MASTERSHIP_CLAIM_TIMEOUT_SECONDS);
  registerThisMember();
}

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

MembershipManager(Node node, ClusterServiceImpl clusterService, Lock clusterServiceLock) {
  this.node = node;
  this.clusterService = clusterService;
  this.clusterServiceLock = clusterServiceLock;
  this.nodeEngine = node.getNodeEngine();
  this.logger = node.getLogger(getClass());
  mastershipClaimTimeoutSeconds = node.getProperties().getInteger(MASTERSHIP_CLAIM_TIMEOUT_SECONDS);
  registerThisMember();
}

代码示例来源：origin: com.hazelcast.simulator/tests-hz36

public static OperationService getOperationService(HazelcastInstance hz) {
  Node node = checkNotNull(getNode(hz), "node is null in Hazelcast instance " + hz);
  NodeEngineImpl nodeEngine = node.getNodeEngine();
  try {
    return nodeEngine.getOperationService();
  } catch (NoSuchMethodError e) {
    // fallback for a binary incompatible change (see commit http://git.io/vtfKU)
    return getOperationServiceViaReflection(nodeEngine);
  }
}

代码示例来源：origin: com.hazelcast.simulator/tests-hz35

public static OperationService getOperationService(HazelcastInstance hz) {
  Node node = checkNotNull(getNode(hz), "node is null in Hazelcast instance " + hz);
  NodeEngineImpl nodeEngine = node.getNodeEngine();
  try {
    return nodeEngine.getOperationService();
  } catch (NoSuchMethodError e) {
    // fallback for a binary incompatible change (see commit http://git.io/vtfKU)
    return getOperationServiceViaReflection(nodeEngine);
  }
}