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