|
|
@ -128,12 +128,12 @@ public class QuotaCheckReactiveFilter implements WebFilter, Ordered {
|
|
|
|
if (Objects.nonNull(quotaResponse.getActiveRule())) {
|
|
|
|
if (Objects.nonNull(quotaResponse.getActiveRule())) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
String encodedActiveRuleName = URLEncoder.encode(
|
|
|
|
String encodedActiveRuleName = URLEncoder.encode(
|
|
|
|
quotaResponse.getActiveRule().getName().getValue(), UTF_8);
|
|
|
|
quotaResponse.getActiveRuleName(), UTF_8);
|
|
|
|
response.getHeaders().add(HeaderConstant.INTERNAL_ACTIVE_RULE_NAME, encodedActiveRuleName);
|
|
|
|
response.getHeaders().add(HeaderConstant.INTERNAL_ACTIVE_RULE_NAME, encodedActiveRuleName);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
catch (UnsupportedEncodingException e) {
|
|
|
|
catch (UnsupportedEncodingException e) {
|
|
|
|
LOG.error("Cannot encode {} for header internal-callee-activerule.",
|
|
|
|
LOG.error("Cannot encode {} for header internal-callee-activerule.",
|
|
|
|
quotaResponse.getActiveRule().getName().getValue(), e);
|
|
|
|
quotaResponse.getActiveRuleName(), e);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return response.writeWith(Mono.just(dataBuffer));
|
|
|
|
return response.writeWith(Mono.just(dataBuffer));
|
|
|
|