From e6209c7c363420d27f8dc7ed1d286448a61cac56 Mon Sep 17 00:00:00 2001 From: Craig Perkins Date: Fri, 29 Sep 2023 11:12:29 -0400 Subject: [PATCH] Minor update Signed-off-by: Craig Perkins --- .../org/opensearch/http/netty4/Netty4DefaultHttpRequest.java | 1 - .../org/opensearch/http/netty4/Netty4HttpServerTransport.java | 3 ++- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/modules/transport-netty4/src/main/java/org/opensearch/http/netty4/Netty4DefaultHttpRequest.java b/modules/transport-netty4/src/main/java/org/opensearch/http/netty4/Netty4DefaultHttpRequest.java index 59f5e9f308aa4..2f8ab02d68585 100644 --- a/modules/transport-netty4/src/main/java/org/opensearch/http/netty4/Netty4DefaultHttpRequest.java +++ b/modules/transport-netty4/src/main/java/org/opensearch/http/netty4/Netty4DefaultHttpRequest.java @@ -51,7 +51,6 @@ public String uri() { @Override public BytesReference content() { - // throw new RuntimeException("Not implemented"); return BytesArray.EMPTY; } diff --git a/modules/transport-netty4/src/main/java/org/opensearch/http/netty4/Netty4HttpServerTransport.java b/modules/transport-netty4/src/main/java/org/opensearch/http/netty4/Netty4HttpServerTransport.java index d38cd1609efcf..c82869de4bc8b 100644 --- a/modules/transport-netty4/src/main/java/org/opensearch/http/netty4/Netty4HttpServerTransport.java +++ b/modules/transport-netty4/src/main/java/org/opensearch/http/netty4/Netty4HttpServerTransport.java @@ -504,7 +504,8 @@ protected void initChannel(Channel childChannel) throws Exception { .addLast("decoder_compress", new Netty4ConditionalDecompressor()); if (handlingSettings.isCompression()) { - childChannel.pipeline().addLast("compress", new HttpContentCompressor(handlingSettings.getCompressionLevel())); + childChannel.pipeline() + .addLast("encoder_compress", new HttpContentCompressor(handlingSettings.getCompressionLevel())); } childChannel.pipeline()