Package com.netflix.zuul.sample.push

Class SampleSSEPushChannelInitializer

java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
io.netty.channel.ChannelInitializer<io.netty.channel.Channel>
com.netflix.zuul.netty.server.BaseZuulChannelInitializer
com.netflix.zuul.netty.server.push.PushChannelInitializer
com.netflix.zuul.sample.push.SampleSSEPushChannelInitializer
All Implemented Interfaces:
io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler
public class SampleSSEPushChannelInitializer extends com.netflix.zuul.netty.server.push.PushChannelInitializer
Author: Susheel Aroskar Date: 6/8/18

  • Nested Class Summary

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

    io.netty.channel.ChannelHandler.Sharable

  • Field Summary

    Fields inherited from class com.netflix.zuul.netty.server.BaseZuulChannelInitializer

    accessLogPublisher, ATTR_CHANNEL_CONFIG, channelConfig, channelDependencies, channels, connectionExpiry, filterLoader, filterUsageNotifier, HTTP_CODEC_HANDLER_NAME, HTTP_REQUEST_HEADERS_READ_TIMEOUT, HTTP_REQUEST_HEADERS_READ_TIMEOUT_ENABLED, httpMetricsHandler, httpRequestHeadersReadTimeoutCounter, httpRequestHeadersReadTimer, httpRequestReadTimeout, httpRequestReadTimeoutCounter, idleTimeout, MAX_CHUNK_SIZE, MAX_HEADER_SIZE, MAX_INITIAL_LINE_LENGTH, maxConnections, maxConnectionsHandler, maxRequestsPerConnection, maxRequestsPerConnectionInBrownout, metricId, nettyLogger, passportLoggingHandler, perEventLoopConnectionMetricsHandler, perEventLoopRequestsMetricsHandler, port, rateLimitingChannelHandler, registry, requestCompleteHandler, sessionContextDecorator, sourceAddressChannelHandler, sslClientCertCheckChannelHandler, stripInboundProxyHeadersHandler, withProxyProtocol

  • Constructor Summary

    Constructors
    Constructor
    Description
    SampleSSEPushChannelInitializer(String metricId, com.netflix.netty.common.channel.config.ChannelConfig channelConfig, com.netflix.netty.common.channel.config.ChannelConfig channelDependencies, io.netty.channel.group.ChannelGroup channels)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    addPushHandlers(io.netty.channel.ChannelPipeline pipeline)
     

    Methods inherited from class com.netflix.zuul.netty.server.push.PushChannelInitializer

    addHttp1Handlers, addHttpRelatedHandlers, initChannel

    Methods inherited from class com.netflix.zuul.netty.server.BaseZuulChannelInitializer

    addPassportHandler, addSslClientCertChecks, addSslInfoHandlers, addTcpRelatedHandlers, addTimeoutHandlers, addZuulFilterChainHandler, addZuulHandlers, createHttpServerCodec, getEndpointRunner, getFilterChainRunner, getFilterChainRunner, getFilters, storeChannel

    Methods inherited from class io.netty.channel.ChannelInitializer

    channelRegistered, exceptionCaught, handlerAdded, handlerRemoved

    Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

    channelActive, channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggered

    Methods inherited from class io.netty.channel.ChannelHandlerAdapter

    ensureNotSharable, isSharable

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • SampleSSEPushChannelInitializer

      public SampleSSEPushChannelInitializer(String metricId, com.netflix.netty.common.channel.config.ChannelConfig channelConfig, com.netflix.netty.common.channel.config.ChannelConfig channelDependencies, io.netty.channel.group.ChannelGroup channels)

  • Method Details

    • addPushHandlers

      protected void addPushHandlers(io.netty.channel.ChannelPipeline pipeline)
      Specified by:
      addPushHandlers in class com.netflix.zuul.netty.server.push.PushChannelInitializer