Class ServerH2StreamMultiplexer

java.lang.Object

org.apache.hc.core5.http2.impl.nio.AbstractH2StreamMultiplexer

org.apache.hc.core5.http2.impl.nio.ServerH2StreamMultiplexer

All Implemented Interfaces:

Closeable, AutoCloseable, HttpConnection, SocketModalCloseable, ModalCloseable, Identifiable

@Internal
public class ServerH2StreamMultiplexer
extends AbstractH2StreamMultiplexer

I/O event handler for events fired by ProtocolIOSession that implements server side HTTP/2 messaging protocol with full support for multiplexed message transmission.

Since:

5.0

Nested Class Summary

Nested classes/interfaces inherited from class AbstractH2StreamMultiplexer

AbstractH2StreamMultiplexer.ConnectionHandshake, AbstractH2StreamMultiplexer.H2StreamChannelImpl, AbstractH2StreamMultiplexer.SettingsHandshake

Field Summary

Fields

Modifier and Type	Field	Description
private final HandlerFactory<AsyncServerExchangeHandler>	exchangeHandlerFactory

Constructor Summary

Constructors

Constructor	Description
ServerH2StreamMultiplexer(ProtocolIOSession ioSession, HttpProcessor httpProcessor, HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, CharCodingConfig charCodingConfig, H2Config h2Config)
ServerH2StreamMultiplexer(ProtocolIOSession ioSession, FrameFactory frameFactory, HttpProcessor httpProcessor, HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, CharCodingConfig charCodingConfig, H2Config h2Config, H2StreamListener streamListener)

Method Summary

Modifier and Type	Method	Description
(package private) void	acceptHeaderFrame()
(package private) void	acceptPushFrame()
(package private) void	acceptPushRequest()
(package private) boolean	allowGracefulAbort(H2Stream stream)
(package private) List<Header>	decodeHeaders(ByteBuffer payload)
(package private) H2Setting[]	generateSettings(H2Config localConfig)
(package private) H2StreamHandler	incomingPushPromise(H2StreamChannel channel, HandlerFactory<AsyncPushConsumer> pushHandlerFactory)
(package private) H2StreamHandler	incomingRequest(H2StreamChannel channel)
(package private) H2StreamHandler	outgoingPushPromise(H2StreamChannel channel, AsyncPushProducer pushProducer)
(package private) H2StreamHandler	outgoingRequest(H2StreamChannel channel, AsyncClientExchangeHandler exchangeHandler, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpContext context)
String	toString()
(package private) void	validateSetting(H2Param param, int value)

Methods inherited from class AbstractH2StreamMultiplexer

appendState, close, close, createChannel, createStream, getConnMetrics, getEndpointDetails, getHttpProcessor, getId, getLocalAddress, getProtocolVersion, getRemoteAddress, getSocketTimeout, getSSLSession, isOpen, onConnect, onDisconnect, onException, onInput, onOutput, onTimeout, requestSessionOutput, setSocketTimeout, submitCommand

Methods inherited from class Object

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

Field Details

exchangeHandlerFactory

private final HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory

Constructor Details

ServerH2StreamMultiplexer

public ServerH2StreamMultiplexer(ProtocolIOSession ioSession,
 FrameFactory frameFactory,
 HttpProcessor httpProcessor,
 HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory,
 CharCodingConfig charCodingConfig,
 H2Config h2Config,
 H2StreamListener streamListener)

ServerH2StreamMultiplexer

public ServerH2StreamMultiplexer(ProtocolIOSession ioSession,
 HttpProcessor httpProcessor,
 HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory,
 CharCodingConfig charCodingConfig,
 H2Config h2Config)

Method Details

validateSetting

void validateSetting(H2Param param,
 int value)
              throws H2ConnectionException

Specified by:

validateSetting in class AbstractH2StreamMultiplexer

Throws:

H2ConnectionException

generateSettings

H2Setting[] generateSettings(H2Config localConfig)

Specified by:

generateSettings in class AbstractH2StreamMultiplexer

acceptHeaderFrame

void acceptHeaderFrame()

Specified by:

acceptHeaderFrame in class AbstractH2StreamMultiplexer

acceptPushRequest

void acceptPushRequest()

Specified by:

acceptPushRequest in class AbstractH2StreamMultiplexer

acceptPushFrame

void acceptPushFrame()
              throws H2ConnectionException

Specified by:

acceptPushFrame in class AbstractH2StreamMultiplexer

Throws:

H2ConnectionException

incomingRequest

H2StreamHandler incomingRequest(H2StreamChannel channel)

Specified by:

incomingRequest in class AbstractH2StreamMultiplexer

outgoingRequest

H2StreamHandler outgoingRequest(H2StreamChannel channel,
 AsyncClientExchangeHandler exchangeHandler,
 HandlerFactory<AsyncPushConsumer> pushHandlerFactory,
 HttpContext context)
                         throws IOException

Specified by:

outgoingRequest in class AbstractH2StreamMultiplexer

Throws:

IOException

incomingPushPromise

H2StreamHandler incomingPushPromise(H2StreamChannel channel,
 HandlerFactory<AsyncPushConsumer> pushHandlerFactory)
                             throws IOException

Specified by:

incomingPushPromise in class AbstractH2StreamMultiplexer

Throws:

IOException

outgoingPushPromise

H2StreamHandler outgoingPushPromise(H2StreamChannel channel,
 AsyncPushProducer pushProducer)
                             throws IOException

Specified by:

outgoingPushPromise in class AbstractH2StreamMultiplexer

Throws:

IOException

allowGracefulAbort

boolean allowGracefulAbort(H2Stream stream)

Specified by:

allowGracefulAbort in class AbstractH2StreamMultiplexer

decodeHeaders

List<Header> decodeHeaders(ByteBuffer payload)
                    throws HttpException

Overrides:

decodeHeaders in class AbstractH2StreamMultiplexer

Throws:

HttpException

toString

public String toString()

Overrides:

toString in class Object