org.thales.punch.netty.relp.impl

Class NettyRelpServerImpl

java.lang.Object

org.thales.punch.netty.impl.NettyAbstractEndpoint

org.thales.punch.netty.impl.NettyAbstractServer

org.thales.punch.netty.relp.impl.NettyRelpServerImpl

All Implemented Interfaces:

Runnable, NettySocketServer<RELPFrame>

public class NettyRelpServerImpl
extends NettyAbstractServer
implements NettySocketServer<RELPFrame>

An extra simple Netty TCP server, reading lines from a TCP socket. Supports compression and ssl. Note that it delimiters lines using '\n', '\r\n' or '\0'

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
NettyRelpServerImpl(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	run() Effectively runs the server.
NettyRelpServerImpl	setCallback(INettyReaderCallback<RELPFrame> 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

NettyRelpServerImpl

public NettyRelpServerImpl(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 -

metricsContext - the metric context

Method Detail

setCallback

public NettyRelpServerImpl setCallback(INettyReaderCallback<RELPFrame> handler)

Specified by:

setCallback in interface NettySocketServer<RELPFrame>

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<RELPFrame>

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<RELPFrame>

Parameters:

address - the host port address.