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