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