This commit is contained in:
@@ -126,7 +126,7 @@ public class ServiceWatchService extends AbstractWatchService {
|
|||||||
Object dest = null;
|
Object dest = null;
|
||||||
for (NodeServer ns : application.getNodeServers()) {
|
for (NodeServer ns : application.getNodeServers()) {
|
||||||
ResourceFactory resFactory = ns.getResourceFactory();
|
ResourceFactory resFactory = ns.getResourceFactory();
|
||||||
List list = resFactory.query((n, s) -> name.equals(n) && s.getClass().getName().endsWith(type));
|
List list = resFactory.query((n, s) -> name.equals(n) && s != null && s.getClass().getName().endsWith(type));
|
||||||
if (list == null || list.isEmpty()) continue;
|
if (list == null || list.isEmpty()) continue;
|
||||||
dest = list.get(0);
|
dest = list.get(0);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user