修改ps

mpusher · Jan 29, 2016 · 2080baf · 2080baf
1 parent 6495596
commit 2080baf
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 4 deletions.
diff --git a/mpush-cs/src/main/java/com/shinemo/mpush/cs/ConnectionServerMain.java b/mpush-cs/src/main/java/com/shinemo/mpush/cs/ConnectionServerMain.java
@@ -5,10 +5,8 @@
 import com.shinemo.mpush.api.Server;
 import com.shinemo.mpush.common.AbstractServer;
 import com.shinemo.mpush.common.app.impl.GatewayServerApplication;
-import com.shinemo.mpush.common.zk.listener.impl.GatewayServerPathListener;
 import com.shinemo.mpush.core.server.ConnectionServer;
 import com.shinemo.mpush.core.server.GatewayServer;
-import com.shinemo.mpush.cs.zk.listener.impl.ConnectionServerPathListener;
 import com.shinemo.mpush.tools.Jsons;
 
 public class ConnectionServerMain extends AbstractServer<ConnectionServerApplication>{

diff --git a/mpush-ps/src/main/java/com/shinemo/mpush/ps/GatewayClientMain.java b/mpush-ps/src/main/java/com/shinemo/mpush/ps/GatewayClientMain.java
@@ -4,7 +4,7 @@
 
 import com.shinemo.mpush.api.PushSender.Callback;
 import com.shinemo.mpush.common.AbstractClient;
-import com.shinemo.mpush.common.zk.listener.impl.GatewayServerPathListener;
+import com.shinemo.mpush.ps.zk.listener.impl.GatewayServerPathListener;
 
 public class GatewayClientMain extends AbstractClient {
 

diff --git a/mpush-ps/src/main/java/com/shinemo/mpush/ps/PushRequest.java b/mpush-ps/src/main/java/com/shinemo/mpush/ps/PushRequest.java
@@ -7,6 +7,7 @@
 import com.shinemo.mpush.common.message.gateway.GatewayPushMessage;
 import com.shinemo.mpush.common.router.ConnectionRouterManager;
 import com.shinemo.mpush.common.router.RemoteRouter;
+import com.shinemo.mpush.ps.manage.impl.GatewayServerManage;
 import com.shinemo.mpush.tools.spi.ServiceContainer;
 
 import io.netty.channel.ChannelFuture;
@@ -20,7 +21,7 @@
  */
 public class PushRequest implements PushSender.Callback, Runnable {
 
-	private static GatewayClientManage gatewayClientManage = (GatewayClientManage)ServiceContainer.getInstance(ServerManage.class, "gatewayClientManage");
+	private static GatewayServerManage gatewayClientManage = (GatewayServerManage)ServiceContainer.getInstance(ServerManage.class, "gatewayClientManage");
 
     private static final Logger LOGGER = LoggerFactory.getLogger(PushRequest.class);
     private PushSender.Callback callback;