#283 update code

vipshop · Nov 8, 2017 · d68251d · d68251d
1 parent c939c6a
commit d68251d
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/saturn-core/src/main/java/com/vip/saturn/job/internal/sharding/ShardingListenerManager.java b/saturn-core/src/main/java/com/vip/saturn/job/internal/sharding/ShardingListenerManager.java
@@ -141,9 +141,7 @@ public void process(WatchedEvent event) throws Exception {
 			case NodeCreated:
 			case NodeDataChanged:
 				log.info("event type:{}, path:{}", event.getType(), event.getPath());
-				if (shardingService.isNeedSharding()) {
-					doBusiness();
-				}
+				doBusiness();
 			default:
 				// use the thread pool to executor registerNecessaryWatcher by async,
 				// fix the problem: