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

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

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

Node.getConfig介绍

暂无

代码示例

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

@Override
public Config getConfig() {
  return node.getConfig();
}

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

@Override
public Config getConfig() {
  return node.getConfig();
}

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

public NodeIOService(Node node, NodeEngineImpl nodeEngine) {
  this.node = node;
  this.nodeEngine = nodeEngine;
  restApiConfig = initRestApiConfig(node.getProperties(), node.getConfig());
  memcacheProtocolConfig = initMemcacheProtocolConfig(node.getProperties(), node.getConfig());
}

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

@Override
public SSLConfig getSSLConfig() {
  return node.getConfig().getNetworkConfig().getSSLConfig();
}

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

@Override
public SymmetricEncryptionConfig getSymmetricEncryptionConfig() {
  return node.getConfig().getNetworkConfig().getSymmetricEncryptionConfig();
}

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

@Override
public SSLConfig getSSLConfig() {
  return node.getConfig().getNetworkConfig().getSSLConfig();
}

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

private boolean checkCredentials(HttpPostCommand command) throws UnsupportedEncodingException {
  byte[] data = command.getData();
  final String[] strList = bytesToString(data).split("&");
  if (strList.length < 2) {
    return false;
  }
  final String groupName = URLDecoder.decode(strList[0], "UTF-8");
  final String groupPass = URLDecoder.decode(strList[1], "UTF-8");
  final GroupConfig groupConfig = textCommandService.getNode().getConfig().getGroupConfig();
  return groupConfig.getName().equals(groupName) && groupConfig.getPassword().equals(groupPass);
}

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

@Override
  public WanReplicationPublisherDelegate createNew(String name) {
    final WanReplicationConfig wanReplicationConfig = node.getConfig().getWanReplicationConfig(name);
    if (wanReplicationConfig == null) {
      return null;
    }
    final List<WanPublisherConfig> publisherConfigs = wanReplicationConfig.getWanPublisherConfigs();
    return new WanReplicationPublisherDelegate(name, createPublishers(wanReplicationConfig, publisherConfigs));
  }
};

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

@Override
  public WanReplicationPublisherDelegate createNew(String name) {
    final WanReplicationConfig wanReplicationConfig = node.getConfig().getWanReplicationConfig(name);
    if (wanReplicationConfig == null) {
      return null;
    }
    final List<WanPublisherConfig> publisherConfigs = wanReplicationConfig.getWanPublisherConfigs();
    return new WanReplicationPublisherDelegate(name, createPublishers(wanReplicationConfig, publisherConfigs));
  }
};

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

public TcpIpJoinerOverAWS(Node node) {
  super(node);
  logger = node.getLogger(getClass());
  AwsConfig awsConfig = node.getConfig().getNetworkConfig().getJoin().getAwsConfig();
  aws = new AWSClient(awsConfig);
}

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

@Override
public Collection<Integer> getOutboundPorts() {
  final NetworkConfig networkConfig = node.getConfig().getNetworkConfig();
  final Collection<Integer> outboundPorts = networkConfig.getOutboundPorts();
  final Collection<String> outboundPortDefinitions = networkConfig.getOutboundPortDefinitions();
  return AddressUtil.getOutboundPorts(outboundPorts, outboundPortDefinitions);
}

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

@Override
public Collection<Integer> getOutboundPorts() {
  final NetworkConfig networkConfig = node.getConfig().getNetworkConfig();
  final Collection<Integer> outboundPorts = networkConfig.getOutboundPorts();
  final Collection<String> outboundPortDefinitions = networkConfig.getOutboundPortDefinitions();
  return AddressUtil.getOutboundPorts(outboundPorts, outboundPortDefinitions);
}

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

public TcpIpJoinerOverAWS(Node node) {
  super(node);
  logger = node.getLogger(getClass());
  AwsConfig awsConfig = fromDeprecatedAwsConfig(node.getConfig().getNetworkConfig().getJoin().getAwsConfig());
  aws = new AWSClient(awsConfig);
}

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

@Override
protected int getConnTimeoutSeconds() {
  AwsConfig awsConfig = node.getConfig().getNetworkConfig().getJoin().getAwsConfig();
  return awsConfig.getConnectionTimeoutSeconds();
}

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

public TcpIpJoinerOverAWS(Node node) {
  super(node);
  logger = node.getLogger(getClass());
  AwsConfig awsConfig = fromDeprecatedAwsConfig(node.getConfig().getNetworkConfig().getJoin().getAwsConfig());
  aws = new AWSClient(awsConfig);
}

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

@Override
protected int getConnTimeoutSeconds() {
  AwsConfig awsConfig = fromDeprecatedAwsConfig(node.getConfig().getNetworkConfig().getJoin().getAwsConfig());
  return awsConfig.getConnectionTimeoutSeconds();
}

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

@Override
protected int getConnTimeoutSeconds() {
  AwsConfig awsConfig = fromDeprecatedAwsConfig(node.getConfig().getNetworkConfig().getJoin().getAwsConfig());
  return awsConfig.getConnectionTimeoutSeconds();
}

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

private void registerServices(Map<String, Properties> serviceProps, Map<String, Object> serviceConfigObjects) {
  registerCoreServices();
  registerExtensionServices();
  Node node = nodeEngine.getNode();
  ServicesConfig servicesConfig = node.getConfig().getServicesConfig();
  if (servicesConfig != null) {
    registerDefaultServices(servicesConfig);
    registerUserServices(servicesConfig, serviceProps, serviceConfigObjects);
  }
}

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

private void registerServices(Map<String, Properties> serviceProps, Map<String, Object> serviceConfigObjects) {
  registerCoreServices();
  registerExtensionServices();
  Node node = nodeEngine.getNode();
  ServicesConfig servicesConfig = node.getConfig().getServicesConfig();
  if (servicesConfig != null) {
    registerDefaultServices(servicesConfig);
    registerUserServices(servicesConfig, serviceProps, serviceConfigObjects);
  }
}

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

public PartitionStateManager(Node node, InternalPartitionServiceImpl partitionService, PartitionListener listener) {
  this.node = node;
  this.logger = node.getLogger(getClass());
  this.partitionService = partitionService;
  this.partitionCount = partitionService.getPartitionCount();
  this.partitions = new InternalPartitionImpl[partitionCount];
  PartitionReplica localReplica = PartitionReplica.from(node.getLocalMember());
  for (int i = 0; i < partitionCount; i++) {
    this.partitions[i] = new InternalPartitionImpl(i, listener, localReplica);
  }
  memberGroupFactory = MemberGroupFactoryFactory.newMemberGroupFactory(node.getConfig().getPartitionGroupConfig(),
      node.getDiscoveryService());
  partitionStateGenerator = new PartitionStateGeneratorImpl();
}

相关文章

微信公众号

最新文章

更多