Skip to content

Commit

Permalink
rename
Browse files Browse the repository at this point in the history
  • Loading branch information
AlbumenJ committed Aug 16, 2022
1 parent 35b8bcb commit a09c405
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Expand Up @@ -37,7 +37,7 @@ public NacosAggregateListener(NotifyListener notifyListener) {
this.notifyListener = notifyListener;
}

public List<Instance> saveAndAggregatedInstances(String serviceName, List<Instance> instances) {
public List<Instance> saveAndAggregateAllInstances(String serviceName, List<Instance> instances) {
serviceNames.add(serviceName);
serviceInstances.put(serviceName, instances);
return serviceInstances.values().stream().flatMap(List::stream).collect(Collectors.toList());
Expand Down
Expand Up @@ -573,7 +573,7 @@ private void notifySubscriber(URL url, String serviceName, NacosAggregateListene
// Instances
filterEnabledInstances(enabledInstances);
}
List<URL> aggregatedUrls = toUrlWithEmpty(url, listener.saveAndAggregatedInstances(serviceName, enabledInstances));
List<URL> aggregatedUrls = toUrlWithEmpty(url, listener.saveAndAggregateAllInstances(serviceName, enabledInstances));
NacosRegistry.this.notify(url, listener.getNotifyListener(), aggregatedUrls);
}

Expand Down

0 comments on commit a09c405

Please sign in to comment.