代码初步调整完毕

mpusher · Jan 17, 2016 · 5ebc3c8 · 5ebc3c8
1 parent 71a4a5c
commit 5ebc3c8
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/mpush-cs/src/main/java/com/shinemo/mpush/cs/client/ConnectionClientMain.java b/mpush-cs/src/main/java/com/shinemo/mpush/cs/client/ConnectionClientMain.java
@@ -4,14 +4,15 @@
 
 import com.google.common.collect.Lists;
 import com.shinemo.mpush.common.AbstractClient;
+import com.shinemo.mpush.common.manage.ServerManage;
 import com.shinemo.mpush.cs.ConnectionServerApplication;
-import com.shinemo.mpush.cs.manage.impl.ConnectionServerManage;
 import com.shinemo.mpush.cs.zk.listener.impl.ConnectionServerPathListener;
 import com.shinemo.mpush.tools.spi.ServiceContainer;
 
 public class ConnectionClientMain extends AbstractClient {
 
-	private static ConnectionServerManage  connectionServerManage = ServiceContainer.getInstance(ConnectionServerManage.class);
+	@SuppressWarnings("unchecked")
+	private ServerManage<ConnectionServerApplication> connectionServerManage = ServiceContainer.getInstance(ServerManage.class);
 
 	public ConnectionClientMain() {
 		registerListener(new ConnectionServerPathListener());

diff --git a/mpush-cs/src/main/java/com/shinemo/mpush/cs/client/Main.java b/mpush-cs/src/main/java/com/shinemo/mpush/cs/client/Main.java
@@ -1,6 +1,7 @@
 package com.shinemo.mpush.cs.client;
 
 import java.util.List;
+import java.util.concurrent.locks.LockSupport;
 
 import com.shinemo.mpush.api.Client;
 import com.shinemo.mpush.cs.ConnectionServerApplication;
@@ -28,6 +29,8 @@ public void run() {
 		});
 		t.setDaemon(false);
 		t.start();
+
+		LockSupport.park();
 
 	}