lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
地平线
2015-08-10 16:46:53 +08:00
parent 3e4d8ba02b
commit f5a72b29ec
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/com/wentch/redkale/boot/Application.java
View File

@@ -58,7 +58,7 @@ public final class Application {
public static final String RESNAME_SNCP_GROUP = "SNCP_GROUP";
//当前SNCP Server的IP地址+端口 类型: SocketAddress、InetSocketAddress
public static final String RESNAME_SNCP_ADDRESS = "SNCP_ADDRESS";
public static final String RESNAME_SNCP_ADDR = "SNCP_ADDR";
//当前SNCP Server的IP地址+端口集合 类型: Map<InetSocketAddress, String>、HashMap<InetSocketAddress, String>
public static final String RESNAME_SNCP_NODES = "SNCP_NODES";

4
src/com/wentch/redkale/boot/NodeSncpServer.java
View File

@@ -31,8 +31,8 @@ public final class NodeSncpServer extends NodeServer {
this.servaddr = addr;
this.nodeGroup = application.addrGroups.getOrDefault(addr, "");
this.consumer = server == null ? null : x -> server.addService(x);
this.factory.register(RESNAME_SNCP_ADDRESS, SocketAddress.class, this.servaddr);
this.factory.register(RESNAME_SNCP_ADDRESS, InetSocketAddress.class, this.servaddr);
this.factory.register(RESNAME_SNCP_ADDR, SocketAddress.class, this.servaddr);
this.factory.register(RESNAME_SNCP_ADDR, InetSocketAddress.class, this.servaddr);
this.factory.register(RESNAME_SNCP_GROUP, this.nodeGroup);
}