org.thales.punch.netty.impl

Class NettyHttpServerImpl

java.lang.Object

org.thales.punch.netty.impl.NettyAbstractEndpoint

org.thales.punch.netty.impl.NettyAbstractServer

org.thales.punch.netty.impl.NettyHttpServerImpl

All Implemented Interfaces:

Runnable, INettyReaderCallback<Map<String,Object>>, NettySocketServer<Map<String,Object>>

public class NettyHttpServerImpl
extends NettyAbstractServer
implements INettyReaderCallback<Map<String,Object>>, NettySocketServer<Map<String,Object>>

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
NettyHttpServerImpl(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.
Class<?>	getType()
void	onReceive(io.netty.channel.ChannelHandlerContext ctx, INettyTuple<Map<String,Object>> in) Called when a NettySocketServer has received data.
void	run() Effectively runs the server.
NettyHttpServerImpl	setCallback(INettyReaderCallback<Map<String,Object>> 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.INettyReaderCallback

onActive, onInactive, onThrowable

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

isStopped, stop

Constructor Detail

NettyHttpServerImpl

public NettyHttpServerImpl(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 settings

metricsContext - the metric context

Method Detail

setCallback

public NettyHttpServerImpl setCallback(INettyReaderCallback<Map<String,Object>> handler)

Specified by:

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

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,Object>>

onReceive

public void onReceive(io.netty.channel.ChannelHandlerContext ctx,
                      INettyTuple<Map<String,Object>> in)

Description copied from interface: INettyReaderCallback

Called when a NettySocketServer has received data.

Specified by:

onReceive in interface INettyReaderCallback<Map<String,Object>>

Parameters:

ctx - the receiving channel context .

in - the received data.

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,Object>>

Parameters:

address - the host port address.

getType

public Class<?> getType()

Specified by:

getType in interface INettyReaderCallback<Map<String,Object>>

Returns:

the associated return type.