Skip to content

Commit

Permalink
Single netty request class
Browse files Browse the repository at this point in the history
Signed-off-by: Craig Perkins <[email protected]>
  • Loading branch information
cwperks committed Oct 5, 2023
1 parent a9bf8b9 commit 93ca9ab
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,8 @@

import io.netty.channel.ChannelHandlerContext;
import org.opensearch.http.HttpHandlingSettings;
import org.opensearch.http.netty4.Netty4DefaultHttpRequest;
import org.opensearch.http.netty4.Netty4HttpChannel;
import org.opensearch.http.netty4.Netty4HttpRequest;
import org.opensearch.http.netty4.Netty4HttpServerTransport;
import org.opensearch.rest.RestRequest;
import org.opensearch.security.filter.SecurityRestFilter;
Expand Down Expand Up @@ -88,7 +88,7 @@ public void channelRead0(ChannelHandlerContext ctx, DefaultHttpRequest msg) thro
}

final Netty4HttpChannel httpChannel = ctx.channel().attr(Netty4HttpServerTransport.HTTP_CHANNEL_KEY).get();
final Netty4DefaultHttpRequest httpRequest = new Netty4DefaultHttpRequest(msg);
final Netty4HttpRequest httpRequest = new Netty4HttpRequest(msg);
RestRequest restRequest = AbstractHttpServerTransport.createRestRequest(xContentRegistry, httpRequest, httpChannel);

InterceptingRestChannel interceptingRestChannel = new InterceptingRestChannel(
Expand Down

0 comments on commit 93ca9ab

Please sign in to comment.