reverse

meiping05 · Oct 15, 2018 · 18ebf50 · 18ebf50
1 parent 07dd8f6
commit 18ebf50
Showing 1 changed file with 2 additions and 17 deletions.
diff --git a/...main/java/io/shardingsphere/orchestration/internal/rule/OrchestrationMasterSlaveRule.java b/...main/java/io/shardingsphere/orchestration/internal/rule/OrchestrationMasterSlaveRule.java
@@ -17,8 +17,6 @@
 
 package io.shardingsphere.orchestration.internal.rule;
 
-import com.google.common.base.Predicate;
-import com.google.common.collect.Iterators;
 import com.google.common.eventbus.Subscribe;
 import io.shardingsphere.api.config.MasterSlaveRuleConfiguration;
 import io.shardingsphere.core.rule.MasterSlaveRule;
@@ -61,20 +59,7 @@ public Collection<String> getSlaveDataSourceNames() {
      */
     @Subscribe
     public void renew(final DisabledStateEventBusEvent disabledStateEventBusEvent) {
-        if (disabledStateEventBusEvent.getDisabledDataSourceNames().isEmpty()) {
-            disabledDataSourceNames.clear();
-        } else {
-            disabledDataSourceNames.addAll(disabledStateEventBusEvent.getDisabledDataSourceNames());
-        }
-    }
-
-    private boolean isToRenew(final Collection<String> disabledDataSourceNames) {
-        return Iterators.contains(disabledDataSourceNames.iterator(), new Predicate<String>() {
-
-            @Override
-            public boolean apply(final String input) {
-                return OrchestrationMasterSlaveRule.super.getSlaveDataSourceNames().contains(input);
-            }
-        });
+        disabledDataSourceNames.clear();
+        disabledDataSourceNames.addAll(disabledStateEventBusEvent.getDisabledDataSourceNames());
     }
 }