From 90a8102ee3fbf4b86b1b9fab23d25fbb6b5cceca Mon Sep 17 00:00:00 2001 From: xueye Date: Fri, 16 Jul 2021 10:37:26 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20=E4=BF=AE=E6=94=B9=E6=88=90?= =?UTF-8?q?=E5=91=98=E5=8F=98=E9=87=8F=E8=AE=BF=E9=97=AE=E6=9D=83=E9=99=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cicdi/notify/AbstractNotifierManager.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/notify-core/src/main/java/com/cicdi/notify/AbstractNotifierManager.java b/notify-core/src/main/java/com/cicdi/notify/AbstractNotifierManager.java index 19c1945..5abd3a6 100644 --- a/notify-core/src/main/java/com/cicdi/notify/AbstractNotifierManager.java +++ b/notify-core/src/main/java/com/cicdi/notify/AbstractNotifierManager.java @@ -13,11 +13,11 @@ import java.util.concurrent.ConcurrentHashMap; */ public abstract class AbstractNotifierManager implements NotifierManager { - private final Map> providers = new ConcurrentHashMap<>(); + protected final Map> providers = new ConcurrentHashMap<>(); - private final Map notifiers = new ConcurrentHashMap<>(); + protected final Map notifiers = new ConcurrentHashMap<>(); - private final NotifyConfigManager configManager; + protected final NotifyConfigManager configManager; // private EventBus eventBus; @@ -47,12 +47,12 @@ public abstract class AbstractNotifierManager implements NotifierManager { if (null == provider) { throw new UnsupportedOperationException("不支持的服务商: " + properties.getProvider()); } - Notifier notifier1 = provider.createNotifier(properties); - Notifier notifier2 = notifiers.put(properties.getId(), notifier1); - if (null != notifier2) { - notifier2.close(); + Notifier notifierNew = provider.createNotifier(properties); + Notifier notifierOld = notifiers.put(properties.getId(), notifierNew); + if (null != notifierOld) { + notifierOld.close(); } - return notifier1; + return notifierNew; } @Override