org.thales.punch.netty.impl

Class NettyInitializer

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

org.thales.punch.netty.impl.NettyInitializer

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

Direct Known Subclasses:

NettyInitializerClient, NettyInitializerHttpClient, NettyInitializerHttpServer, NettyInitializerLumberjackClient, NettyInitializerLumberjackServer, NettyInitializerRelpServer, NettyInitializerServer

public abstract class NettyInitializer
extends io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

All initializers share the metrics, the compression and the ssl context (if any). Also shared are some common socket options such as read timeout and read timeout action.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	NettyInitializer.CompressionRatio

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
protected String	readSocketTimeoutAction what to do if the timeout occurs.
protected long	readSocketTimeoutMs automatically do something if no data is read
protected io.netty.handler.ssl.SslContext	sslCtx ssl context if enabled
protected boolean	useNettyCompression turn on/off netty level compression

Constructor Summary

Constructors

Constructor and Description
NettyInitializer(org.thales.punch.libraries.metrics.api.IMetricContext metricsContext, io.netty.handler.ssl.SslContext sslCtx, boolean useNettyCompression, long readSocketTimeoutMs, String readSocketTimeoutAction)

Method Summary

Modifier and Type	Method and Description
protected com.codahale.metrics.Counter	getAppRecvCounter()
protected com.codahale.metrics.Counter	getAppSentCounter()
protected com.codahale.metrics.Counter	getRawRecvCounter()
protected com.codahale.metrics.Counter	getRawSentCounter()

Methods inherited from class io.netty.channel.ChannelInitializer

channelRegistered, exceptionCaught, handlerAdded, handlerRemoved, initChannel

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

Field Detail

sslCtx

protected io.netty.handler.ssl.SslContext sslCtx

ssl context if enabled

readSocketTimeoutMs

protected long readSocketTimeoutMs

automatically do something if no data is read

readSocketTimeoutAction

protected String readSocketTimeoutAction

what to do if the timeout occurs. Default action is to close the peer

useNettyCompression

protected boolean useNettyCompression

turn on/off netty level compression

Constructor Detail

NettyInitializer

public NettyInitializer(org.thales.punch.libraries.metrics.api.IMetricContext metricsContext,
                        io.netty.handler.ssl.SslContext sslCtx,
                        boolean useNettyCompression,
                        long readSocketTimeoutMs,
                        String readSocketTimeoutAction)

Parameters:

metricsContext - the metric context

sslCtx - a ssl context if needed

useNettyCompression - true to qctivate netty level compression

readSocketTimeoutMs -

readSocketTimeoutAction -

Method Detail

getRawRecvCounter

protected com.codahale.metrics.Counter getRawRecvCounter()

getRawSentCounter

protected com.codahale.metrics.Counter getRawSentCounter()

getAppRecvCounter

protected com.codahale.metrics.Counter getAppRecvCounter()

getAppSentCounter

protected com.codahale.metrics.Counter getAppSentCounter()