feat:support concurrency rate limit.

pull/1455/head
Haotian Zhang 11 months ago
parent 35f6f34501
commit 7391283b51

@ -56,21 +56,21 @@ public final class MetadataContextHolder {
} }
public static MetadataContext get() { public static MetadataContext get() {
try {
return (MetadataContext) com.tencent.polaris.metadata.core.manager.MetadataContextHolder.getOrCreate(); return (MetadataContext) com.tencent.polaris.metadata.core.manager.MetadataContextHolder.getOrCreate();
} }
catch (Throwable throwable) {
LOG.error("Failed to get or create MetadataContext.", throwable);
return null;
}
}
private static MetadataContext createMetadataManager() { private static MetadataContext createMetadataManager() {
MetadataContext metadataManager = new MetadataContext(); MetadataContext metadataManager = new MetadataContext();
if (staticMetadataManager == null) { if (staticMetadataManager == null) {
if (ApplicationContextAwareUtils.getApplicationContext() != null) {
staticMetadataManager = ApplicationContextAwareUtils.getApplicationContext() staticMetadataManager = ApplicationContextAwareUtils.getApplicationContext()
.getBean(StaticMetadataManager.class); .getBean(StaticMetadataManager.class);
} }
else {
// for junit test.
return metadataManager;
}
}
// local custom metadata // local custom metadata
MetadataContainer metadataContainer = metadataManager.getMetadataContainer(MetadataType.CUSTOM, false); MetadataContainer metadataContainer = metadataManager.getMetadataContainer(MetadataType.CUSTOM, false);
Map<String, String> mergedStaticMetadata = staticMetadataManager.getMergedStaticMetadata(); Map<String, String> mergedStaticMetadata = staticMetadataManager.getMergedStaticMetadata();

Loading…
Cancel
Save