From 651dc3df2a0c7b894cb88f74e2ffbf7b82462304 Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Thu, 22 Nov 2018 14:47:58 +0800 Subject: [PATCH] =?UTF-8?q?=E8=BF=98=E5=8E=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/org/redkale/boot/NodeServer.java | 14 ++------------ 1 file changed, 2 insertions(+), 12 deletions(-) diff --git a/src/org/redkale/boot/NodeServer.java b/src/org/redkale/boot/NodeServer.java index f9244bdeb..af76306bb 100644 --- a/src/org/redkale/boot/NodeServer.java +++ b/src/org/redkale/boot/NodeServer.java @@ -240,12 +240,7 @@ public abstract class NodeServer { } if (DataSource.class.isAssignableFrom(sourceType) && can) { // 必须有空构造函数 final Service srcService = (Service) src; - SncpClient client = null; - try { - client = Sncp.getSncpClient(srcService); - } catch (RuntimeException re) { - logger.log(Level.FINE, "maybe new Service by hand", re); - } + SncpClient client = Sncp.getSncpClient(srcService); final InetSocketAddress sncpAddr = client == null ? null : client.getClientAddress(); final Set groups = new HashSet<>(); if (client != null && client.getSameGroup() != null) groups.add(client.getSameGroup()); @@ -260,12 +255,7 @@ public abstract class NodeServer { application.dataSources.add(source); appResFactory.register(resourceName, DataSource.class, source); - SncpClient client = null; - try { //Service成员变量是一个直接new XXXService的字段, 递归ResourceFactory.inject时会导致找不到SncpClient - client = Sncp.getSncpClient((Service) src); - } catch (RuntimeException re) { - logger.log(Level.FINE, "maybe new Service by hand", re); - } + SncpClient client = Sncp.getSncpClient((Service) src); final InetSocketAddress sncpAddr = client == null ? null : client.getClientAddress(); if ((src instanceof DataSource) && sncpAddr != null && resourceFactory.find(resourceName, DataCacheListener.class) == null) { //只有DataSourceService 才能赋值 DataCacheListener final NodeSncpServer sncpServer = application.findNodeSncpServer(sncpAddr);