This commit is contained in:
kamhung
2015-11-23 17:25:44 +08:00
parent e16c233e45
commit a1f62f19c4

View File

@@ -169,8 +169,7 @@ public abstract class NodeServer {
lts = (Transport[]) ts.get(src);
diffGroupTransports = Arrays.asList(lts);
} catch (Exception e) {
logger.log(Level.WARNING, "DataSource inject error " + src, e);
//src 并非 LocalService 对象
//src 不含 MultiRun 方法
}
if (factory.find(rs.name(), DataCacheListener.class) == null) {
Service cacheListenerService = Sncp.createLocalService(rs.name(), getExecutor(), DataCacheListenerService.class, this.sncpAddress, sncpDefaultGroups, sameGroupTransports, diffGroupTransports);