org.thales.punch.netty.impl

Class NettyLumberJackServerImpl

java.lang.Object

org.thales.punch.netty.impl.NettyAbstractEndpoint

org.thales.punch.netty.impl.NettyAbstractServer

org.thales.punch.netty.impl.NettyLumberJackServerImpl

All Implemented Interfaces:

Runnable, NettySocketServer<Map<String,String>>, NettyReaderByteBufCallback

public class NettyLumberJackServerImpl
extends NettyAbstractServer
implements NettyReaderByteBufCallback, NettySocketServer<Map<String,String>>

Field Summary

Fields inherited from class org.thales.punch.netty.impl.NettyAbstractServer

bossGroup, sslCtx, sslSessionResumption, workerGroup

Fields inherited from class org.thales.punch.netty.impl.NettyAbstractEndpoint

bootstrap, host, maxPayloadLength, metricsContext, port, protocol, readSocketTimeoutAction, readSocketTimeoutMs, ssl, sslCiphers, sslProtocol, sslProvider, useNettyCompression

Constructor Summary

Constructors

Constructor and Description
NettyLumberJackServerImpl(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Create a new single-threaded asynchronous TCP server.

Method Summary

Modifier and Type	Method and Description
void	addListeningAddress(org.thales.punch.settings.api.ISettingsMap address) Add a listening socket to this server thread.
void	onReceive(io.netty.channel.ChannelHandlerContext ctx, io.netty.buffer.ByteBuf in, com.codahale.metrics.Counter rec, com.codahale.metrics.Counter sent) Called when a NettySocketServer has received data.
void	run() Effectively runs the server.
NettyLumberJackServerImpl	setCallback(INettyReaderCallback<Map<String,String>> handler)
String	toString()

Methods inherited from class org.thales.punch.netty.impl.NettyAbstractServer

isStopped, start, stop

Methods inherited from class org.thales.punch.netty.impl.NettyAbstractEndpoint

getFileFromString, getSslProvider

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.thales.punch.netty.api.NettySocketServer

isStopped, stop

Constructor Detail

NettyLumberJackServerImpl

public NettyLumberJackServerImpl(org.thales.punch.settings.api.ISettingsMap settings,
                                 org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Create a new single-threaded asynchronous TCP server. Once created it must be initialized.

Parameters:

settings - the configuration settings

metricsContext - provider of metrics name prefix, metrics registry and metrics context tags

Method Detail

setCallback

public NettyLumberJackServerImpl setCallback(INettyReaderCallback<Map<String,String>> handler)

Specified by:

setCallback in interface NettySocketServer<Map<String,String>>

Parameters:

handler - your data callback

Returns:

this server

toString

public String toString()

Overrides:

toString in class Object

run

public void run()

Description copied from interface: NettySocketServer

Effectively runs the server. Does not return unless a call to NettySocketServer.stop() is made.

Specified by:

run in interface Runnable

Specified by:

run in interface NettySocketServer<Map<String,String>>

onReceive

public void onReceive(io.netty.channel.ChannelHandlerContext ctx,
                      io.netty.buffer.ByteBuf in,
                      com.codahale.metrics.Counter rec,
                      com.codahale.metrics.Counter sent)

Description copied from interface: NettyReaderByteBufCallback

Called when a NettySocketServer has received data.

Specified by:

onReceive in interface NettyReaderByteBufCallback

Parameters:

ctx - the receiving channel context .

in - the received data.

rec - the received data counter.

sent - the sent data counter.

addListeningAddress

public void addListeningAddress(org.thales.punch.settings.api.ISettingsMap address)

Description copied from interface: NettySocketServer

Add a listening socket to this server thread.

Specified by:

addListeningAddress in interface NettySocketServer<Map<String,String>>

Parameters:

address - the host port address.