diff --git a/src/com/wentch/redkale/boot/NodeServer.java b/src/com/wentch/redkale/boot/NodeServer.java index 1474d26d5..54055aa27 100644 --- a/src/com/wentch/redkale/boot/NodeServer.java +++ b/src/com/wentch/redkale/boot/NodeServer.java @@ -5,6 +5,7 @@ */ package com.wentch.redkale.boot; +import static com.wentch.redkale.boot.Application.RESNAME_SNCP_GROUP; import com.wentch.redkale.net.sncp.ServiceWrapper; import com.wentch.redkale.net.Server; import com.wentch.redkale.net.sncp.Sncp; @@ -86,6 +87,8 @@ public abstract class NodeServer { final List[] transportses = parseTransport(defgroup, this.nodeGroup, this.servaddr); final List sameGroupTransports = transportses[0]; final List diffGroupTransports = transportses[1]; + + this.factory.register(RESNAME_SNCP_GROUP, !defgroup.isEmpty() ? defgroup : (this.nodeGroup == null ? "" : this.nodeGroup)); //--------------------------------------------------------------------------------------------- final ResourceFactory regFactory = application.factory; factory.add(DataSource.class, (ResourceFactory rf, final Object src, Field field) -> { diff --git a/src/com/wentch/redkale/boot/NodeSncpServer.java b/src/com/wentch/redkale/boot/NodeSncpServer.java index 6d8ead1f8..10b8c5f0c 100644 --- a/src/com/wentch/redkale/boot/NodeSncpServer.java +++ b/src/com/wentch/redkale/boot/NodeSncpServer.java @@ -36,7 +36,6 @@ public final class NodeSncpServer extends NodeServer { this.factory.register(RESNAME_SNCP_ADDR, InetSocketAddress.class, this.servaddr); this.factory.register(RESNAME_SNCP_ADDR, String.class, this.servaddr.getAddress().getHostAddress()); } - this.factory.register(RESNAME_SNCP_GROUP, this.nodeGroup); } @Override