diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/AuthenticationInterceptor.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/AuthenticationInterceptor.java index e79453f9b7..b73c5cb085 100644 --- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/AuthenticationInterceptor.java +++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/AuthenticationInterceptor.java @@ -58,6 +58,7 @@ public class AuthenticationInterceptor implements ServerInterceptor { for (AccessValidator accessValidator : accessValidatorList) { accessValidator.validate(accessValidator.parse(messageV3, metadataHeader)); } + super.onMessage(message); } }; }