Top Description Inners Fields Constructors Methods
io.vertx.core.http.impl

public Class HttpServerWorker

extends Object
implements BiConsumer<Channel, SslChannelProvider>
Class Inheritance
All Implemented Interfaces
java.util.function.BiConsumer
Imports
io.netty.buffer.Unpooled, io.netty.channel.*, io.netty.handler.codec.compression.CompressionOptions, .StandardCompressionOptions, io.netty.handler.codec.haproxy.HAProxyMessageDecoder, io.netty.handler.codec.http.HttpContentCompressor, .HttpContentDecompressor, io.netty.handler.logging.LoggingHandler, io.netty.handler.ssl.SslHandler, io.netty.handler.stream.ChunkedWriteHandler, io.netty.handler.timeout.IdleState, .IdleStateEvent, .IdleStateHandler, io.netty.handler.traffic.GlobalTrafficShapingHandler, io.netty.util.concurrent.Future, .GenericFutureListener, io.vertx.core.Handler, io.vertx.core.http.HttpServerOptions, io.vertx.core.http.impl.cgbystrom.FlashPolicyHandler, io.vertx.core.impl.ContextInternal, .VertxInternal, io.vertx.core.net.impl.*, io.vertx.core.spi.metrics.HttpServerMetrics, java.nio.charset.StandardCharsets, java.util.List, java.util.function.BiConsumer, .Function, .Supplier
A channel initializer that will takes care of configuring a blank channel for HTTP to Vert.x io.vertx.core.http.HttpServerRequest.
Author
Julien Viet

Nested and Inner Type Summary

Modifier and TypeClass and Description
private static class
HttpServerWorker.EncodingDetector

Field Summary

Modifier and TypeField and Description
private final CompressionOptions[]
compressionOptions

pack-priv final Handler<HttpServerConnection>
connectionHandler

pack-priv final ContextInternal
context

private final boolean
disableH2C

private final Function<String, String>
encodingDetector

private final Handler<Throwable>
exceptionHandler

private final boolean
logEnabled

private final HttpServerOptions
options

private final HttpServerImpl
server

private final String
serverOrigin

private final Supplier<ContextInternal>
streamContextSupplier

private final GlobalTrafficShapingHandler
trafficShapingHandler

private final VertxInternal
vertx

Constructor Summary

AccessConstructor and Description
public
HttpServerWorker(ContextInternal context, Supplier<ContextInternal> streamContextSupplier, HttpServerImpl server, VertxInternal vertx, HttpServerOptions options, String serverOrigin, Handler<HttpServerConnection> connectionHandler, Handler<Throwable> exceptionHandler, GlobalTrafficShapingHandler trafficShapingHandler)

Method Summary

Modifier and TypeMethod and Description
public void
accept(Channel
the first input argument
ch, SslChannelProvider
the second input argument
sslChannelProvider)

Implements java.util.function.BiConsumer.accept.

Performs this operation on the given arguments.

pack-priv VertxHttp2ConnectionHandler<Http2ServerConnection>
buildHttp2ConnectionHandler(ContextInternal ctx, Handler<HttpServerConnection> handler_)

pack-priv void
configureHttp1Handler(ChannelPipeline pipeline, SslChannelProvider sslChannelProvider)

private void
configureHttp1OrH2CUpgradeHandler(ChannelPipeline pipeline, SslChannelProvider sslChannelProvider)

private void
configureHttp1Pipeline(ChannelPipeline pipeline)

private void
configureHttp2(ChannelPipeline pipeline)

private void
configureHttp2Handler(ChannelPipeline pipeline)

pack-priv void
configureHttp2Pipeline(ChannelPipeline pipeline)

private void
configurePipeline(Channel ch, SslChannelProvider sslChannelProvider)

private void
handleException(Throwable cause)

private void
sendServiceUnavailable(Channel ch)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

compressionOptionsback to summary
private final CompressionOptions[] compressionOptions
connectionHandlerback to summary
pack-priv final Handler<HttpServerConnection> connectionHandler
contextback to summary
pack-priv final ContextInternal context
disableH2Cback to summary
private final boolean disableH2C
encodingDetectorback to summary
private final Function<String, String> encodingDetector
exceptionHandlerback to summary
private final Handler<Throwable> exceptionHandler
logEnabledback to summary
private final boolean logEnabled
optionsback to summary
private final HttpServerOptions options
serverback to summary
private final HttpServerImpl server
serverOriginback to summary
private final String serverOrigin
streamContextSupplierback to summary
private final Supplier<ContextInternal> streamContextSupplier
trafficShapingHandlerback to summary
private final GlobalTrafficShapingHandler trafficShapingHandler
vertxback to summary
private final VertxInternal vertx

Constructor Detail

HttpServerWorkerback to summary
public HttpServerWorker(ContextInternal context, Supplier<ContextInternal> streamContextSupplier, HttpServerImpl server, VertxInternal vertx, HttpServerOptions options, String serverOrigin, Handler<HttpServerConnection> connectionHandler, Handler<Throwable> exceptionHandler, GlobalTrafficShapingHandler trafficShapingHandler)

Method Detail

acceptback to summary
public void accept(Channel ch, SslChannelProvider sslChannelProvider)

Implements java.util.function.BiConsumer.accept.

Doc from java.util.function.BiConsumer.accept.

Performs this operation on the given arguments.

Parameters
ch:Channel

the first input argument

sslChannelProvider:SslChannelProvider

the second input argument

Annotations
@Override
buildHttp2ConnectionHandlerback to summary
pack-priv VertxHttp2ConnectionHandler<Http2ServerConnection> buildHttp2ConnectionHandler(ContextInternal ctx, Handler<HttpServerConnection> handler_)
configureHttp1Handlerback to summary
pack-priv void configureHttp1Handler(ChannelPipeline pipeline, SslChannelProvider sslChannelProvider)
configureHttp1OrH2CUpgradeHandlerback to summary
private void configureHttp1OrH2CUpgradeHandler(ChannelPipeline pipeline, SslChannelProvider sslChannelProvider)
configureHttp1Pipelineback to summary
private void configureHttp1Pipeline(ChannelPipeline pipeline)
configureHttp2back to summary
private void configureHttp2(ChannelPipeline pipeline)
configureHttp2Handlerback to summary
private void configureHttp2Handler(ChannelPipeline pipeline)
configureHttp2Pipelineback to summary
pack-priv void configureHttp2Pipeline(ChannelPipeline pipeline)
configurePipelineback to summary
private void configurePipeline(Channel ch, SslChannelProvider sslChannelProvider)
handleExceptionback to summary
private void handleException(Throwable cause)
sendServiceUnavailableback to summary
private void sendServiceUnavailable(Channel ch)
io.vertx.core.http.impl back to summary

private Class HttpServerWorker.EncodingDetector

extends HttpContentCompressor
Class Inheritance

Constructor Summary

AccessConstructor and Description
private
EncodingDetector(CompressionOptions[] compressionOptions)

Method Summary

Modifier and TypeMethod and Description
protected String
determineEncoding(String acceptEncoding)

Overrides io.netty.handler.codec.http.HttpContentCompressor.determineEncoding.

Inherited from io.netty.handler.codec.http.HttpContentCompressor:
beginEncodedetermineWrapperhandlerAdded

Constructor Detail

EncodingDetectorback to summary
private EncodingDetector(CompressionOptions[] compressionOptions)

Method Detail

determineEncodingback to summary
protected String determineEncoding(String acceptEncoding)

Overrides io.netty.handler.codec.http.HttpContentCompressor.determineEncoding.

Annotations
@Override