modify renewDisabledDataSourceNames()

meiping05 · Oct 15, 2018 · 5661e61 · 5661e61
1 parent c54781f
commit 5661e61
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sharding-proxy/src/main/java/io/shardingsphere/shardingproxy/runtime/GlobalRegistry.java b/sharding-proxy/src/main/java/io/shardingsphere/shardingproxy/runtime/GlobalRegistry.java
@@ -213,7 +213,7 @@ public void renewCircuitBreakerDataSourceNames(final CircuitStateEventBusEvent c
     @Subscribe
     public void renewDisabledDataSourceNames(final ProxyDisabledStateEventBusEvent disabledStateEventBusEvent) {
         for (Entry<String, ShardingSchema> entry : shardingSchemas.entrySet()) {
-            DisabledStateEventBusEvent disabledEvent = new DisabledStateEventBusEvent(getDisabledDataSourceNames(entry.getKey(), =disabledStateEventBusEvent.getDisabledSchemaDataSourceMap());
+            DisabledStateEventBusEvent disabledEvent = new DisabledStateEventBusEvent(getDisabledDataSourceNames(entry.getKey(), disabledStateEventBusEvent.getDisabledSchemaDataSourceMap()));
             if (entry.getValue().isMasterSlaveOnly()) {
                 renewShardingSchemaWithMasterSlaveRule(entry.getValue(), disabledEvent);
             } else {