diff --git a/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/transcoding/GrpcTranscodingResponse.java b/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/transcoding/GrpcTranscodingResponse.java index 5ce2e18d017ff9..bcf4e9bff3500a 100644 --- a/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/transcoding/GrpcTranscodingResponse.java +++ b/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/transcoding/GrpcTranscodingResponse.java @@ -154,28 +154,6 @@ private Future writeMessage(GrpcMessage message, boolean end) { throw new IllegalStateException(); } - if (encoding != null && message != null && !encoding.equals(message.encoding())) { - switch (encoding) { - case "gzip": - message = GrpcMessageEncoder.GZIP.encode(message.payload()); - break; - case "identity": - if (!message.encoding().equals("identity")) { - if (!message.encoding().equals("gzip")) { - return Future.failedFuture("Encoding " + message.encoding() + " is not supported"); - } - Buffer decoded; - try { - decoded = GrpcMessageDecoder.GZIP.decode(message); - } catch (CodecException e) { - return Future.failedFuture(e); - } - message = GrpcMessage.message("identity", decoded); - } - break; - } - } - boolean trailersOnly = status != GrpcStatus.OK && !headersSent && end; MultiMap responseHeaders = httpResponse.headers(); @@ -187,8 +165,6 @@ private Future writeMessage(GrpcMessage message, boolean end) { } } responseHeaders.set("content-type", "application/json"); - responseHeaders.set("grpc-encoding", encoding); - responseHeaders.set("grpc-accept-encoding", "gzip"); } if (end) {