modify the cat

cat-consumer/src/main/java/com/dianping/cat/consumer/CatConsumerModule.java

 package com.dianping.cat.consumer;
 
 import com.dianping.cat.CatCoreModule;
+import com.dianping.cat.message.io.TcpSocketReceiver;
 import com.site.initialization.AbstractModule;
 import com.site.initialization.Module;
 import com.site.initialization.ModuleContext;
@@ -15,5 +16,8 @@ public class CatConsumerModule extends AbstractModule {
 
 	@Override
 	protected void execute(ModuleContext ctx) {
+		TcpSocketReceiver receiver = ctx.lookup(TcpSocketReceiver.class);
+
+		receiver.startEncoderThreads(3);
 	}
 }

cat-core/src/main/java/com/dianping/cat/CatCoreModule.java

@@ -11,7 +11,6 @@ import com.dianping.cat.configuration.ClientConfigManager;
 import com.dianping.cat.configuration.ClientConfigReloader;
 import com.dianping.cat.configuration.client.entity.ClientConfig;
 import com.dianping.cat.message.internal.MilliSecondTimer;
-import com.dianping.cat.message.io.TcpSocketReceiver;
 import com.dianping.cat.message.io.TransportManager;
 import com.dianping.cat.status.StatusUpdateTask;
 import com.site.helper.Threads;
@@ -54,17 +53,13 @@ public class CatCoreModule extends AbstractModule {
 
 			Threads.forGroup("Cat").start(statusUpdateTask);
 			LockSupport.parkNanos(10 * 1000 * 1000L); // wait 10 ms
-		}
 
-		ClientConfig config = clientConfigManager.getClientConfig();
+			ClientConfig config = clientConfigManager.getClientConfig();
 
-		if (config != null) {
-			Threads.forGroup("Cat").start(new ClientConfigReloader(clientConfigFile.getAbsolutePath(), config));
+			if (config != null) {
+				Threads.forGroup("Cat").start(new ClientConfigReloader(clientConfigFile.getAbsolutePath(), config));
+			}
 		}
-
-		TcpSocketReceiver receiver = ctx.lookup(TcpSocketReceiver.class);
-
-		receiver.startEncoder(3);
 	}
 
 	@Override

cat-core/src/main/java/com/dianping/cat/message/io/TcpSocketReceiver.java

@@ -241,8 +241,8 @@ public class TcpSocketReceiver implements LogEnabled {
 		}
 	}
 
-	public void startEncoder(int size) {
-		for (int i = 0; i < size; i++) {
+	public void startEncoderThreads(int threadSize) {
+		for (int i = 0; i < threadSize; i++) {
 			DecodeMessageTask messageDecoder = new DecodeMessageTask(i);
 
 			Threads.forGroup("Cat").start(messageDecoder);