This commit is contained in:
kamhung
2015-12-02 15:38:48 +08:00
parent 9e690da45f
commit 93d6620ea4

View File

@@ -153,7 +153,7 @@ public abstract class NodeServer {
Resource rs = field.getAnnotation(Resource.class); Resource rs = field.getAnnotation(Resource.class);
if (rs == null) return; if (rs == null) return;
if ((src instanceof Service) && Sncp.isRemote((Service) src)) return; if ((src instanceof Service) && Sncp.isRemote((Service) src)) return;
DataSource source = DataSourceFactory.create(rs.name()); DataSource source = new DataDefaultSource(rs.name());
application.sources.add(source); application.sources.add(source);
regFactory.register(rs.name(), DataSource.class, source); regFactory.register(rs.name(), DataSource.class, source);
List<Transport> sameGroupTransports = sncpSameGroupTransports; List<Transport> sameGroupTransports = sncpSameGroupTransports;