org.microbean.jersey.netty

Class Http2StreamFrameToContainerRequestDecoder

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.handler.codec.MessageToMessageDecoder<T>

org.microbean.jersey.netty.AbstractContainerRequestDecoder<Http2StreamFrame,Http2HeadersFrame,Http2DataFrame>

org.microbean.jersey.netty.Http2StreamFrameToContainerRequestDecoder

All Implemented Interfaces:

ChannelHandler, ChannelInboundHandler

public class Http2StreamFrameToContainerRequestDecoder
extends AbstractContainerRequestDecoder<Http2StreamFrame,Http2HeadersFrame,Http2DataFrame>

An AbstractContainerRequestDecoder that decodes Http2StreamFrames into ContainerRequests.

Author:

Laird Nelson

See Also:

AbstractContainerRequestDecoder.decode(ChannelHandlerContext, Object, List)

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
Http2StreamFrameToContainerRequestDecoder(URI baseUri) Deprecated. Please use the Http2StreamFrameToContainerRequestDecoder(URI, Configuration) constructor instead.
Http2StreamFrameToContainerRequestDecoder(URI baseUri, Configuration configuration) Creates a new Http2StreamFrameToContainerRequestDecoder.
Http2StreamFrameToContainerRequestDecoder(URI baseUri, Supplier<? extends Configuration> configurationSupplier) Creates a new Http2StreamFrameToContainerRequestDecoder.

Method Summary

Modifier and Type	Method and Description
protected String	getMethod(Http2HeadersFrame http2HeadersFrame) Extracts and returns the name of the request method from the supplied message, which is guaranteed to be a "headers" message.
protected String	getRequestUriString(Http2HeadersFrame http2HeadersFrame) Extracts and returns a String representing a request URI from the supplied message, which is guaranteed to be a "headers" message.
protected void	installMessage(ChannelHandlerContext channelHandlerContext, Http2HeadersFrame message, ContainerRequest containerRequest) Overrides the AbstractContainerRequestDecoder.installMessage(ChannelHandlerContext, Object, ContainerRequest) method to additionally install incoming headers into the supplied ContainerRequest.
protected boolean	isLast(Http2StreamFrame http2StreamFrame) Returns true if the supplied Http2StreamFrame is the last of a stream of messages.

Methods inherited from class org.microbean.jersey.netty.AbstractContainerRequestDecoder

acceptInboundMessage, channelReadComplete, createPropertiesDelegate, createSecurityContext, createTerminableByteBufInputStream, decode, getContent, isData, isHeaders

Methods inherited from class io.netty.handler.codec.MessageToMessageDecoder

channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Detail

Http2StreamFrameToContainerRequestDecoder

@Deprecated
public Http2StreamFrameToContainerRequestDecoder(URI baseUri)

Deprecated. Please use the Http2StreamFrameToContainerRequestDecoder(URI, Configuration) constructor instead.

Creates a new Http2StreamFrameToContainerRequestDecoder.

Parameters:

baseUri - a URI that will serve as the base URI in a new ContainerRequest; may be null in which case the return value of URI.create("/") will be used instead

See Also:

Http2StreamFrameToContainerRequestDecoder(URI, Configuration)

Http2StreamFrameToContainerRequestDecoder

public Http2StreamFrameToContainerRequestDecoder(URI baseUri,
                                                 Configuration configuration)

Creates a new Http2StreamFrameToContainerRequestDecoder.

Parameters:

baseUri - a URI that will serve as the base URI in a new ContainerRequest; may be null in which case the return value of URI.create("/") will be used instead

configuration - a Configuration describing how the container is configured; may be null

Http2StreamFrameToContainerRequestDecoder

public Http2StreamFrameToContainerRequestDecoder(URI baseUri,
                                                 Supplier<? extends Configuration> configurationSupplier)

Creates a new Http2StreamFrameToContainerRequestDecoder.

Parameters:

baseUri - a URI that will serve as the base URI in a new ContainerRequest; may be null in which case the return value of URI.create("/") will be used instead

configurationSupplier - a Supplier of Configuration instances describing how the container is configured; may be null

Method Detail

getRequestUriString

protected final String getRequestUriString(Http2HeadersFrame http2HeadersFrame)

Extracts and returns a String representing a request URI from the supplied message, which is guaranteed to be a "headers" message.

This implementation calls http2HeadersFrame.headers().path().toString() and returns the result.

Specified by:

getRequestUriString in class AbstractContainerRequestDecoder<Http2StreamFrame,Http2HeadersFrame,Http2DataFrame>

Parameters:

http2HeadersFrame - the message to interrogate; will not be null

Returns:

a String representing a request URI from the supplied message, or null

getMethod

protected final String getMethod(Http2HeadersFrame http2HeadersFrame)

Extracts and returns the name of the request method from the supplied message, which is guaranteed to be a "headers" message.

This implementation calls http2HeadersFrame.headers().method().toString() and returns the result.

Specified by:

getMethod in class AbstractContainerRequestDecoder<Http2StreamFrame,Http2HeadersFrame,Http2DataFrame>

Parameters:

http2HeadersFrame - the message to interrogate; will not be null

Returns:

a String representing the request method from the supplied message, or null

installMessage

protected void installMessage(ChannelHandlerContext channelHandlerContext,
                              Http2HeadersFrame message,
                              ContainerRequest containerRequest)

Overrides the AbstractContainerRequestDecoder.installMessage(ChannelHandlerContext, Object, ContainerRequest) method to additionally install incoming headers into the supplied ContainerRequest.

Overrides:

installMessage in class AbstractContainerRequestDecoder<Http2StreamFrame,Http2HeadersFrame,Http2DataFrame>

Parameters:

channelHandlerContext - the ChannelHandlerContext in effect; will not be null; supplied for convenience; overrides may (and often do) ignore this parameter

message - the message to install; will not be null

containerRequest - the just-constructed ContainerRequest into which to install the supplied message; will not be null

See Also:

Http2HeadersFrame.headers(), InboundMessageContext.header(String, Object)

isLast

protected final boolean isLast(Http2StreamFrame http2StreamFrame)

Returns true if the supplied Http2StreamFrame is the last of a stream of messages.

This implementation returns true if either:

• http2StreamFrame is an instance of Http2HeadersFrame and its Http2HeadersFrame.isEndStream() method returns true, or
• http2StreamFrame is an instance of Http2DataFrame and its Http2DataFrame.isEndStream() method returns true

Specified by:

isLast in class AbstractContainerRequestDecoder<Http2StreamFrame,Http2HeadersFrame,Http2DataFrame>

Parameters:

http2StreamFrame - the message to interrogate; will not be null

Returns:

true if no further messages in the stream are forthcoming; false otherwise