public class NettyInitializerLumberjackServer extends NettyInitializer
ChannelPipeline for a new channel.NettyInitializer.CompressionRatioreadSocketTimeoutAction, readSocketTimeoutMs, sslCtx, useNettyCompression| Constructor and Description |
|---|
NettyInitializerLumberjackServer(NettyReaderByteBufCallback receiver,
org.thales.punch.libraries.metrics.api.IMetricContext metricsContext,
io.netty.handler.ssl.SslContext sslCtx,
boolean zipped,
long readSocketTimeoutMs,
String readSocketTimeoutAction)
Initialzer for the lumberjack netty channel.
|
| Modifier and Type | Method and Description |
|---|---|
void |
initChannel(io.netty.channel.socket.SocketChannel ch) |
getAppRecvCounter, getAppSentCounter, getRawRecvCounter, getRawSentCounterchannelRegistered, exceptionCaught, handlerAdded, handlerRemovedpublic NettyInitializerLumberjackServer(NettyReaderByteBufCallback receiver, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext, io.netty.handler.ssl.SslContext sslCtx, boolean zipped, long readSocketTimeoutMs, String readSocketTimeoutAction)
Watchout: the zipped flag given here does not set on or off the internal compression as supported by the lumberjck protocol, it sets compression on/off for the whole traffic, at the socket level.
receiver - the data receivermetricsContext - the metric contextsslCtx - a ssl context if required, or nullzipped - to enable socket level compressionreadSocketTimeoutMs - readSocketTimeoutAction - Copyright © 2023. All rights reserved.