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:02:50 +08:00
parent cc54e31de0
commit e6224a4638
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/com/wentch/redkale/boot/NodeServer.java
View File

@@ -82,14 +82,13 @@ public abstract class NodeServer {
} }
private void initResource() { private void initResource() {
if (!isSNCP()) return;
final String defgroup = servconf.getValue("group", ""); //Server节点获取group信息 final String defgroup = servconf.getValue("group", ""); //Server节点获取group信息
final List<Transport>[] transportses = parseTransport(defgroup, this.nodeGroup, this.servaddr); final List<Transport>[] transportses = parseTransport(defgroup, this.nodeGroup, this.servaddr);
final List<Transport> sameGroupTransports = transportses[0]; final List<Transport> sameGroupTransports = transportses[0];
final List<Transport> diffGroupTransports = transportses[1]; final List<Transport> diffGroupTransports = transportses[1];
//--------------------------------------------------------------------------------------------- //---------------------------------------------------------------------------------------------
final ResourceFactory regFactory = application.factory; final ResourceFactory regFactory = application.factory;
regFactory.add(DataSource.class, (ResourceFactory rf, final Object src, Field field) -> { factory.add(DataSource.class, (ResourceFactory rf, final Object src, Field field) -> {
try { try {
Resource rs = field.getAnnotation(Resource.class); Resource rs = field.getAnnotation(Resource.class);
if (rs == null) return; if (rs == null) return;