Skip to content

Commit 8dc2b92

Browse files
fix: fix concurrency limiter not working in tsf. (#673)
Co-authored-by: shedfreewu <[email protected]>
1 parent 11f6241 commit 8dc2b92

File tree

1 file changed

+1
-0
lines changed
  • polaris-plugins/polaris-plugins-connector/connector-consul/src/main/java/com/tencent/polaris/plugins/connector/consul/service/ratelimiting

1 file changed

+1
-0
lines changed

polaris-plugins/polaris-plugins-connector/connector-consul/src/main/java/com/tencent/polaris/plugins/connector/consul/service/ratelimiting/RateLimitingService.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -213,6 +213,7 @@ private List<RateLimitProto.Rule> parseResponse(String decodedValue, String name
213213
if (concurrentThreads != null) {
214214
RateLimitProto.ConcurrencyAmount.Builder concurrencyAmountBuilder = RateLimitProto.ConcurrencyAmount.newBuilder();
215215
concurrencyAmountBuilder.setMaxAmount(concurrentThreads);
216+
ruleBuilder.setResource(RateLimitProto.Rule.Resource.CONCURRENCY);
216217
ruleBuilder.setConcurrencyAmount(concurrencyAmountBuilder);
217218
}
218219

0 commit comments

Comments
 (0)