[ISSUE #3949] allow to add user-defined gRPC Server interceptors.

This commit is contained in:
Jixiang.jjx
2022-07-13 11:29:29 +08:00
committed by zhouxiang
parent 2d594814b8
commit d08dfce4fc
2 changed files with 6 additions and 3 deletions
@@ -17,6 +17,7 @@
package org.apache.rocketmq.proxy.grpc;
import io.grpc.BindableService;
import io.grpc.ServerInterceptor;
import io.grpc.ServerServiceDefinition;
import io.grpc.netty.shaded.io.grpc.netty.GrpcSslContexts;
import io.grpc.netty.shaded.io.grpc.netty.NettyServerBuilder;
@@ -100,6 +101,11 @@ public class GrpcServerBuilder {
return this;
}
public GrpcServerBuilder appendInterceptor(ServerInterceptor interceptor) {
this.serverBuilder.intercept(interceptor);
return this;
}
public GrpcServer build() {
return new GrpcServer(this.serverBuilder.build());
}
@@ -21,9 +21,6 @@ import io.grpc.Context;
import io.grpc.Metadata;
public class InterceptorConstants {
private InterceptorConstants() {
}
public static final Context.Key<Metadata> METADATA = Context.key("rpc-metadata");
/**