shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/cache/subscriber/ScalingRegistrySubscriber.java
/**
     * Cache rule configuration.
     *
     * @param event rule configuration cached event
     */
Cache rule configuration.
@param event rule configuration cached event
Cache rule configuration . @param event rule configuration cached event
@Subscribe
    public void cacheRuleConfiguration(final RuleConfigurationCachedEvent event) {
        StartScalingEvent startScalingEvent = new StartScalingEvent(event.getSchemaName(),
                repository.get(SchemaMetaDataNode.getMetaDataDataSourcePath(event.getSchemaName())),
                repository.get(SchemaMetaDataNode.getRulePath(event.getSchemaName())),
                registryCacheManager.loadCache(SchemaMetaDataNode.getRulePath(event.getSchemaName()), event.getCacheId()), event.getCacheId());
        ShardingSphereEventBus.getInstance().post(startScalingEvent);
    }
@ Subscribe public void cacheRuleConfiguration ( final RuleConfigurationCachedEvent event ) { StartScalingEvent startScalingEvent = new StartScalingEvent ( event . getSchemaName ( ) , repository . get ( SchemaMetaDataNode . getMetaDataDataSourcePath ( event . getSchemaName ( ) ) ) , repository . get ( SchemaMetaDataNode . getRulePath ( event . getSchemaName ( ) ) ) , registryCacheManager . loadCache ( SchemaMetaDataNode . getRulePath ( event . getSchemaName ( ) ) , event . getCacheId ( ) ) , event . getCacheId ( ) ) ; ShardingSphereEventBus . getInstance ( ) . post ( startScalingEvent ) ; }
Cache rule configuration.
Cache rule configuration .