提交 45bac2a8 编写于 作者: F Frankie Wu

remove unused CatClientModule class

上级 0fd2b8fb
package com.dianping.cat;
import java.io.File;
import java.io.InputStream;
import java.util.concurrent.locks.LockSupport;
import com.dianping.cat.configuration.ClientConfigManager;
import com.dianping.cat.configuration.ClientConfigMerger;
import com.dianping.cat.configuration.client.entity.ClientConfig;
import com.dianping.cat.configuration.client.transform.DefaultDomParser;
import com.dianping.cat.message.io.TransportManager;
import com.dianping.cat.status.StatusUpdateTask;
import com.site.helper.Files;
import com.site.helper.Threads;
import com.site.initialization.AbstractModule;
import com.site.initialization.DefaultModuleContext;
import com.site.initialization.Module;
import com.site.initialization.ModuleContext;
public class CatClientModule extends AbstractModule {
public static final String ID = "cat-client";
private static final String CAT_CLIENT_XML = "/META-INF/cat/client.xml";
@Override
protected void execute(final ModuleContext ctx) throws Exception {
File clientConfigFile = ctx.getAttribute("cat-client-config-file");
ClientConfigManager clientConfigManager = ctx.lookup(ClientConfigManager.class);
clientConfigManager.initialize(clientConfigFile);
// warm up Cat
Cat.getInstance().setContainer(((DefaultModuleContext) ctx).getContainer());
// bring up TransportManager
ctx.lookup(TransportManager.class);
// start status update task
if (clientConfigManager.isCatEnabled()) {
StatusUpdateTask statusUpdateTask = ctx.lookup(StatusUpdateTask.class);
Threads.forGroup("Cat").start(statusUpdateTask);
LockSupport.parkNanos(10 * 1000 * 1000L); // wait 10 ms
}
}
@Override
public Module[] getDependencies(ModuleContext ctx) {
return ctx.getModules(CatCoreModule.ID);
}
ClientConfig loadClientConfig(ModuleContext ctx, File configFile) {
ClientConfig globalConfig = null;
ClientConfig clientConfig = null;
try {
// read the global configure from local file system
// so that OPS can:
// - configure the cat servers to connect
// - enable/disable Cat for specific domain(s)
if (configFile != null) {
if (configFile.exists()) {
String xml = Files.forIO().readFrom(configFile.getCanonicalFile(), "utf-8");
globalConfig = new DefaultDomParser().parse(xml);
ctx.info(String.format("Global config file(%s) found.", configFile));
} else {
ctx.warn(String.format("Global config file(%s) not found, IGNORED.", configFile));
}
}
// load the client configure from Java class-path
if (clientConfig == null) {
InputStream in = Thread.currentThread().getContextClassLoader().getResourceAsStream(CAT_CLIENT_XML);
if (in == null) {
in = Cat.class.getResourceAsStream(CAT_CLIENT_XML);
}
if (in != null) {
String xml = Files.forIO().readFrom(in, "utf-8");
clientConfig = new DefaultDomParser().parse(xml);
}
}
} catch (Exception e) {
throw new RuntimeException(String.format("Error when loading configuration file(%s)!", configFile), e);
}
// merge the two configures together to make it effected
if (globalConfig != null && clientConfig != null) {
globalConfig.accept(new ClientConfigMerger(clientConfig));
}
return clientConfig;
}
}
......@@ -3,7 +3,6 @@ package com.dianping.cat.build;
import java.util.ArrayList;
import java.util.List;
import com.dianping.cat.CatClientModule;
import com.dianping.cat.CatCoreModule;
import com.dianping.cat.configuration.ClientConfigManager;
import com.dianping.cat.configuration.ServerConfigManager;
......@@ -105,7 +104,6 @@ public class ComponentsConfigurator extends AbstractResourceConfigurator {
.req(ServerConfigManager.class, MessagePathBuilder.class));
all.add(C(Module.class, CatCoreModule.ID, CatCoreModule.class));
all.add(C(Module.class, CatClientModule.ID, CatClientModule.class));
all.addAll(new CodecComponentConfigurator().defineComponents());
all.addAll(new StorageComponentConfigurator().defineComponents());
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册