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

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

本文整理了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

  1. @Override
  2. public Config getConfig() {
  3.   return node.getConfig();
  4. }

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

  1. @Override
  2. public Config getConfig() {
  3.   return node.getConfig();
  4. }

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

  1. public NodeIOService(Node node, NodeEngineImpl nodeEngine) {
  2.   this.node = node;
  3.   this.nodeEngine = nodeEngine;
  4.   restApiConfig = initRestApiConfig(node.getProperties(), node.getConfig());
  5.   memcacheProtocolConfig = initMemcacheProtocolConfig(node.getProperties(), node.getConfig());
  6. }

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

  1. @Override
  2. public SSLConfig getSSLConfig() {
  3.   return node.getConfig().getNetworkConfig().getSSLConfig();
  4. }

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

  1. @Override
  2. public SymmetricEncryptionConfig getSymmetricEncryptionConfig() {
  3.   return node.getConfig().getNetworkConfig().getSymmetricEncryptionConfig();
  4. }

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

  1. @Override
  2. public SSLConfig getSSLConfig() {
  3.   return node.getConfig().getNetworkConfig().getSSLConfig();
  4. }

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

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

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

  1. @Override
  2.   public WanReplicationPublisherDelegate createNew(String name) {
  3.     final WanReplicationConfig wanReplicationConfig = node.getConfig().getWanReplicationConfig(name);
  4.     if (wanReplicationConfig == null) {
  5.       return null;
  6.     }
  7.     final List<WanPublisherConfig> publisherConfigs = wanReplicationConfig.getWanPublisherConfigs();
  8.     return new WanReplicationPublisherDelegate(name, createPublishers(wanReplicationConfig, publisherConfigs));
  9.   }
  10. };

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

  1. @Override
  2.   public WanReplicationPublisherDelegate createNew(String name) {
  3.     final WanReplicationConfig wanReplicationConfig = node.getConfig().getWanReplicationConfig(name);
  4.     if (wanReplicationConfig == null) {
  5.       return null;
  6.     }
  7.     final List<WanPublisherConfig> publisherConfigs = wanReplicationConfig.getWanPublisherConfigs();
  8.     return new WanReplicationPublisherDelegate(name, createPublishers(wanReplicationConfig, publisherConfigs));
  9.   }
  10. };

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

  1. private void registerServices(Map<String, Properties> serviceProps, Map<String, Object> serviceConfigObjects) {
  2.   registerCoreServices();
  3.   registerExtensionServices();
  4.   Node node = nodeEngine.getNode();
  5.   ServicesConfig servicesConfig = node.getConfig().getServicesConfig();
  6.   if (servicesConfig != null) {
  7.     registerDefaultServices(servicesConfig);
  8.     registerUserServices(servicesConfig, serviceProps, serviceConfigObjects);
  9.   }
  10. }

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

  1. private void registerServices(Map<String, Properties> serviceProps, Map<String, Object> serviceConfigObjects) {
  2.   registerCoreServices();
  3.   registerExtensionServices();
  4.   Node node = nodeEngine.getNode();
  5.   ServicesConfig servicesConfig = node.getConfig().getServicesConfig();
  6.   if (servicesConfig != null) {
  7.     registerDefaultServices(servicesConfig);
  8.     registerUserServices(servicesConfig, serviceProps, serviceConfigObjects);
  9.   }
  10. }

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

  1. public PartitionStateManager(Node node, InternalPartitionServiceImpl partitionService, PartitionListener listener) {
  2.   this.node = node;
  3.   this.logger = node.getLogger(getClass());
  4.   this.partitionService = partitionService;
  5.   this.partitionCount = partitionService.getPartitionCount();
  6.   this.partitions = new InternalPartitionImpl[partitionCount];
  7.   PartitionReplica localReplica = PartitionReplica.from(node.getLocalMember());
  8.   for (int i = 0; i < partitionCount; i++) {
  9.     this.partitions[i] = new InternalPartitionImpl(i, listener, localReplica);
  10.   }
  11.   memberGroupFactory = MemberGroupFactoryFactory.newMemberGroupFactory(node.getConfig().getPartitionGroupConfig(),
  12.       node.getDiscoveryService());
  13.   partitionStateGenerator = new PartitionStateGeneratorImpl();
  14. }

内容来源于网络，如有侵权，请联系作者删除！

Node

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Node类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com