org.thales.punch.netty.impl

Class NettyUdpServerImpl<T>

java.lang.Object

org.thales.punch.netty.impl.NettyUdpServerImpl<T>

Type Parameters:

T - the data class type

All Implemented Interfaces:

Runnable, NettySocketServer<T>

public class NettyUdpServerImpl<T>
extends Object
implements NettySocketServer<T>

An extra simple Netty UDP server

Constructor Summary

Constructors

Constructor and Description
NettyUdpServerImpl(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.
boolean	isStopped()
void	run() Effectively runs the server.
NettyUdpServerImpl<T>	setCallback(INettyReaderCallback<T> handler)
void	stop() Stop the server.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyUdpServerImpl

public NettyUdpServerImpl(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 associated metricsContext

Method Detail

setCallback

public NettyUdpServerImpl<T> setCallback(INettyReaderCallback<T> handler)

Specified by:

setCallback in interface NettySocketServer<T>

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

stop

public void stop()

Description copied from interface: NettySocketServer

Stop the server.

Specified by:

stop in interface NettySocketServer<T>

isStopped

public boolean isStopped()

Specified by:

isStopped in interface NettySocketServer<T>

Returns:

true if the server is stopped

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

Parameters:

address - the host port address.