diff --git a/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/supports/RequestScopeHandlerInterceptor.java b/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/supports/RequestScopeHandlerInterceptor.java index 40ed99d29f5e5..966bff2988e57 100644 --- a/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/supports/RequestScopeHandlerInterceptor.java +++ b/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/supports/RequestScopeHandlerInterceptor.java @@ -9,6 +9,7 @@ import io.grpc.ServerInterceptor; import io.grpc.Status; import io.quarkus.arc.Arc; +import io.quarkus.arc.InjectableContext; import io.quarkus.arc.ManagedContext; import io.vertx.core.Context; import io.vertx.core.Handler; @@ -31,9 +32,13 @@ public ServerCall.Listener interceptCall(ServerCall(call) { @Override @@ -43,7 +48,7 @@ public void close(Status status, Metadata trailers) { capturedVertxContext.runOnContext(new Handler() { @Override public void handle(Void ignored) { - reqContext.deactivate(); + reqContext.destroy(state); } }); }