natas_hw
/
dubbo
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

🐛 fix push metadata code location (#11712)

This commit is contained in:
songxiaosheng 2023-03-06 15:05:59 +08:00 committed by GitHub
parent 4903cab551
commit b35312ae49
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/AbstractServiceDiscovery.java
View File

@ -363,19 +363,19 @@ public abstract class AbstractServiceDiscovery implements ServiceDiscovery {
}
TimePair timePair = TimePair.start();
GlobalMetricsEventMulticaster eventMulticaster = applicationModel.getBeanFactory().getBean(GlobalMetricsEventMulticaster.class);
eventMulticaster.publishEvent(new MetadataEvent.PushEvent(applicationModel, timePair));
if (metadataReport != null) {
SubscriberMetadataIdentifier identifier = new SubscriberMetadataIdentifier(serviceName, metadataInfo.getRevision());
if ((DEFAULT_METADATA_STORAGE_TYPE.equals(metadataType) && metadataReport.shouldReportMetadata()) || REMOTE_METADATA_STORAGE_TYPE.equals(metadataType)) {
try {
eventMulticaster.publishEvent(new MetadataEvent.PushEvent(applicationModel, timePair));
metadataReport.publishAppMetadata(identifier, metadataInfo);
eventMulticaster.publishFinishEvent(new MetadataEvent.PushEvent(applicationModel, timePair));
} catch (IllegalStateException e) {
eventMulticaster.publishErrorEvent(new MetadataEvent.PushEvent(applicationModel, timePair));
throw e;
}
}
}
eventMulticaster.publishFinishEvent(new MetadataEvent.PushEvent(applicationModel, timePair));
MetadataInfo clonedMetadataInfo = metadataInfo.clone();
metadataInfos.put(metadataInfo.getRevision(), new MetadataInfoStat(clonedMetadataInfo));
}