-
Notifications
You must be signed in to change notification settings - Fork 1.5k
/
ConnectionServerMain.java
36 lines (25 loc) · 1.06 KB
/
ConnectionServerMain.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
package com.shinemo.mpush.cs;
import com.shinemo.mpush.api.Server;
import com.shinemo.mpush.core.AbstractServer;
import com.shinemo.mpush.core.server.ConnectionServer;
import com.shinemo.mpush.cs.zk.listener.impl.ConnectionServerPathListener;
import com.shinemo.mpush.cs.zk.listener.impl.PushServerPathListener;
import com.shinemo.mpush.cs.zk.listener.impl.RedisPathListener;
import com.shinemo.mpush.tools.config.ConfigCenter;
public class ConnectionServerMain extends AbstractServer<ConnectionServerApplication>{
public ConnectionServerMain(){
registerListener(new RedisPathListener());
registerListener(new PushServerPathListener());
registerListener(new ConnectionServerPathListener());
}
@Override
public Server getServer() {
final int port = ConfigCenter.holder.connectionServerPort();
ConnectionServer connectionServer = new ConnectionServer(port);
return connectionServer;
}
public static void main(String[] args) {
ConnectionServerMain connectionServerMain = new ConnectionServerMain();
connectionServerMain.start();
}
}