File tree Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Original file line number Diff line number Diff line change @@ -334,6 +334,7 @@ protected async override Task ExecuteConfigListen()
334
334
{
335
335
var listenCachesMap = new Dictionary < string , List < CacheData > > ( ) ;
336
336
var removeListenCachesMap = new Dictionary < string , List < CacheData > > ( ) ;
337
+ var hasChangedKeys = false ;
337
338
338
339
// TODO: should update logic here.....
339
340
foreach ( var item in _cacheMap . Values )
@@ -392,6 +393,7 @@ protected async override Task ExecuteConfigListen()
392
393
393
394
if ( configChangeBatchListenResponse . ChangedConfigs != null && configChangeBatchListenResponse . ChangedConfigs . Any ( ) )
394
395
{
396
+ hasChangedKeys = true ;
395
397
foreach ( var item in configChangeBatchListenResponse . ChangedConfigs )
396
398
{
397
399
var changeKey = GroupKey . GetKeyTenant ( item . DataId , item . Group , item . Tenant ) ;
@@ -450,6 +452,9 @@ protected async override Task ExecuteConfigListen()
450
452
}
451
453
}
452
454
}
455
+
456
+ if ( hasChangedKeys )
457
+ await NotifyListenConfig ( ) . ConfigureAwait ( false ) ;
453
458
}
454
459
455
460
private async Task RefreshContentAndCheck ( string groupKey , bool notify )
You can’t perform that action at this time.
0 commit comments