com.hazelcast.config.Config.getManagementCenterConfig()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(7.8k)|赞(0)|评价(0)|浏览(154)

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

Config.getManagementCenterConfig介绍

[英]Returns the management center configuration for this hazelcast instance.
[中]返回此hazelcast实例的管理中心配置。

代码示例

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

@Override
public ManagementCenterConfig getManagementCenterConfig() {
  return staticConfig.getManagementCenterConfig();
}

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

@Override
public ManagementCenterConfig getManagementCenterConfig() {
  return staticConfig.getManagementCenterConfig();
}

代码示例来源:origin: com.sitewhere/sitewhere-core

/**
 * Configure Hazelcast Management Center.
 * 
 * @param config
 */
public static void configureManagementCenter(Config config) {
config.getManagementCenterConfig().setEnabled(true).setUrl("http://localhost:8787/mancenter");
}

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

private void manCenterXmlGenerator(XmlGenerator gen, Config config) {
  if (config.getManagementCenterConfig() != null) {
    ManagementCenterConfig mcConfig = config.getManagementCenterConfig();
    gen.open("management-center",
        "enabled", mcConfig.isEnabled(),
        "update-interval", mcConfig.getUpdateInterval());
    gen.node("url", mcConfig.getUrl());
    if (mcConfig.getUrl() != null) {
      mcMutualAuthConfigXmlGenerator(gen, config.getManagementCenterConfig());
    }
    gen.close();
  }
}

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

private void manCenterXmlGenerator(XmlGenerator gen, Config config) {
  if (config.getManagementCenterConfig() != null) {
    ManagementCenterConfig mcConfig = config.getManagementCenterConfig();
    gen.open("management-center",
        "enabled", mcConfig.isEnabled(),
        "scripting-enabled", mcConfig.isScriptingEnabled(),
        "update-interval", mcConfig.getUpdateInterval());
    gen.node("url", mcConfig.getUrl());
    if (mcConfig.getUrl() != null) {
      mcMutualAuthConfigXmlGenerator(gen, config.getManagementCenterConfig());
    }
    gen.close();
  }
}

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

private void handleMcMutualAuthConfig(Node node) {
  MCMutualAuthConfig mcMutualAuthConfig = new MCMutualAuthConfig();
  NamedNodeMap attributes = node.getAttributes();
  Node enabledNode = attributes.getNamedItem("enabled");
  boolean enabled = enabledNode != null && getBooleanValue(getTextContent(enabledNode).trim());
  mcMutualAuthConfig.setEnabled(enabled);
  for (Node n : childElements(node)) {
    String nodeName = cleanNodeName(n);
    if ("factory-class-name".equals(nodeName)) {
      mcMutualAuthConfig.setFactoryClassName(getTextContent(n).trim());
    } else if ("properties".equals(nodeName)) {
      fillProperties(n, mcMutualAuthConfig.getProperties());
    }
  }
  config.getManagementCenterConfig().setMutualAuthConfig(mcMutualAuthConfig);
}

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

private void handleMcMutualAuthConfig(Node node) {
  MCMutualAuthConfig mcMutualAuthConfig = new MCMutualAuthConfig();
  NamedNodeMap attributes = node.getAttributes();
  Node enabledNode = attributes.getNamedItem("enabled");
  boolean enabled = enabledNode != null && getBooleanValue(getTextContent(enabledNode).trim());
  mcMutualAuthConfig.setEnabled(enabled);
  for (Node n : childElements(node)) {
    String nodeName = cleanNodeName(n);
    if ("factory-class-name".equals(nodeName)) {
      mcMutualAuthConfig.setFactoryClassName(getTextContent(n).trim());
    } else if ("properties".equals(nodeName)) {
      fillProperties(n, mcMutualAuthConfig.getProperties());
    }
  }
  config.getManagementCenterConfig().setMutualAuthConfig(mcMutualAuthConfig);
}

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

private void handleManagementCenterConfig(Node node) {
  NamedNodeMap attrs = node.getAttributes();
  Node enabledNode = attrs.getNamedItem("enabled");
  boolean enabled = enabledNode != null && getBooleanValue(getTextContent(enabledNode));
  Node intervalNode = attrs.getNamedItem("update-interval");
  int interval = intervalNode != null ? getIntegerValue("update-interval",
      getTextContent(intervalNode)) : ManagementCenterConfig.UPDATE_INTERVAL;
  ManagementCenterConfig managementCenterConfig = config.getManagementCenterConfig();
  managementCenterConfig.setEnabled(enabled);
  managementCenterConfig.setUpdateInterval(interval);
  Node scriptingEnabledNode = attrs.getNamedItem("scripting-enabled");
  if (scriptingEnabledNode != null) {
    managementCenterConfig.setScriptingEnabled(getBooleanValue(getTextContent(scriptingEnabledNode)));
  }
  handleManagementCenterChildElements(node, managementCenterConfig);
}

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

@Override
public void run() {
  ManagementCenterConfig managementCenterConfig = getNodeEngine().getConfig().getManagementCenterConfig();
  if (!managementCenterConfig.isScriptingEnabled()) {
    throw new AccessControlException("Using ScriptEngine is not allowed on this Hazelcast member.");
  }
  ScriptEngineManager scriptEngineManager = ScriptEngineManagerContext.getScriptEngineManager();
  ScriptEngine engine = scriptEngineManager.getEngineByName(engineName);
  if (engine == null) {
    throw new IllegalArgumentException("Could not find ScriptEngine named '" + engineName + "'.");
  }
  engine.put("hazelcast", getNodeEngine().getHazelcastInstance());
  try {
    this.result = engine.eval(script);
  } catch (ScriptException e) {
    // ScriptException's cause is not serializable - we don't need the cause
    HazelcastException hazelcastException = new HazelcastException(e.getMessage());
    hazelcastException.setStackTrace(e.getStackTrace());
    throw hazelcastException;
  }
}

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

getTextContent(intervalNode)) : ManagementCenterConfig.UPDATE_INTERVAL;
ManagementCenterConfig managementCenterConfig = config.getManagementCenterConfig();
managementCenterConfig.setEnabled(enabled);
managementCenterConfig.setUpdateInterval(interval);

代码示例来源:origin: hazelcast/hazelcast-code-samples

config.getManagementCenterConfig()
   .setEnabled(true).setUrl("http://" + MANCENTER_SERVICE_NAME + ":8080/hazelcast-mancenter");

代码示例来源:origin: wu191287278/spring-boot-starter-dubbo

config.getManagementCenterConfig().setEnabled(true);
config.getManagementCenterConfig().setUrl(managerUrl);
config.getManagementCenterConfig().setUpdateInterval(url.getParameter("updateInterval", 5));

代码示例来源:origin: lumongo/lumongo

cfg.setInstanceName("" + hazelcastPort);
cfg.getManagementCenterConfig().setEnabled(false);

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

public TimedMemberState createTimedMemberState() {
  MemberStateImpl memberState = new MemberStateImpl();
  Collection<StatisticsAwareService> services = instance.node.nodeEngine.getServices(StatisticsAwareService.class);
  TimedMemberState timedMemberState = new TimedMemberState();
  createMemberState(memberState, services);
  timedMemberState.setMaster(instance.node.isMaster());
  timedMemberState.setMemberList(new ArrayList<String>());
  if (timedMemberState.isMaster()) {
    Set<Member> memberSet = instance.getCluster().getMembers();
    for (Member member : memberSet) {
      MemberImpl memberImpl = (MemberImpl) member;
      Address address = memberImpl.getAddress();
      timedMemberState.getMemberList().add(address.getHost() + ":" + address.getPort());
    }
  }
  timedMemberState.setMemberState(memberState);
  GroupConfig groupConfig = instance.getConfig().getGroupConfig();
  timedMemberState.setClusterName(groupConfig.getName());
  SSLConfig sslConfig = instance.getConfig().getNetworkConfig().getSSLConfig();
  timedMemberState.setSslEnabled(sslConfig != null && sslConfig.isEnabled());
  timedMemberState.setLite(instance.node.isLiteMember());
  SocketInterceptorConfig interceptorConfig = instance.getConfig().getNetworkConfig().getSocketInterceptorConfig();
  timedMemberState.setSocketInterceptorEnabled(interceptorConfig != null && interceptorConfig.isEnabled());
  ManagementCenterConfig managementCenterConfig = instance.node.getConfig().getManagementCenterConfig();
  timedMemberState.setScriptingEnabled(managementCenterConfig.isScriptingEnabled());
  return timedMemberState;
}

相关文章

微信公众号

最新文章

更多

Config类方法