如何在Java中捕获所有传入的gRPC消息？

import io.grpc.*;

public class MessageInterceptor implements ServerInterceptor {
    @Override
    public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) {
        ServerCall.Listener<ReqT> listener = next.startCall(call, headers);
        
        return new ForwardingServerCallListener.SimpleForwardingServerCallListener<ReqT>(listener) {
            @Override
            public void onMessage(ReqT message) {
                // 处理传入的请求消息
                System.out.println("Received request message: " + message.toString());
                
                // 继续处理gRPC调用链
                super.onMessage(message);
            }
            
            @Override
            public void onHalfClose() {
                // 处理传入的半关闭事件
                System.out.println("Received half-close event");
                
                // 继续处理gRPC调用链
                super.onHalfClose();
            }
            
            @Override
            public void onCancel() {
                // 处理传入的取消事件
                System.out.println("Received cancel event");
                
                // 继续处理gRPC调用链
                super.onCancel();
            }
            
            @Override
            public void onComplete() {
                // 处理传入的完成事件
                System.out.println("Received complete event");
                
                // 继续处理gRPC调用链
                super.onComplete();
            }
        };
    }
}

Server server = ServerBuilder.forPort(8080)
        .addService(new YourServiceImplementation())
        .intercept(new MessageInterceptor())
        .build();