org.thales.punch.netty.api

Class NettyFactory

java.lang.Object

org.thales.punch.netty.api.NettyFactory

public class NettyFactory
extends Object

The factor class to get TCP clients or servers.

Author:

dimi

Method Summary

Modifier and Type	Method and Description
static NettyHttpClientImpl	getHttpClient(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Returns a HTTP client.
static NettyHttpClientImpl	getHttpClient(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext, NettyDataAcker acker) Returns a HTTP client.
static NettySocketServer<Map<String,Object>>	getHttpServer(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Return an HTTP server.
static NettyTcpClient<Map<String,String>>	getLumberjackClient(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext, NettyDataAcker acker) Return a TCP client.
static NettySocketServer<RELPFrame>	getRelpServer(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Return a plain TCP server.
static NettySocketServer<String>	getServer(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Return a line based UDP or TCP server.
static NettySocketServer<String>	getSnmpServer(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Return a Line based TCP server.
static NettyTcpClient<String>	getTcpClient(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)
static NettyTcpClient<String>	getTcpClient(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext, NettyDataAcker acker)
static NettySocketServer<Map<String,String>>	getTcpLumberjackServer(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Return a TCP Lumberjack Server server.
static <T> NettySocketServer<T>	getTcpServer(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Return a Line based TCP server.
static NettyUdpClient	getUdpClient(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Return a UDP client.
static <T> NettySocketServer<T>	getUdpServer(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Return a TCP server.

Methods inherited from class java.lang.Object

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

Method Detail

getTcpClient

public static NettyTcpClient<String> getTcpClient(org.thales.punch.settings.api.ISettingsMap settings,
                                                  org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Parameters:

settings - the caller settings

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

Returns:

a netty based TCP client.

getTcpClient

public static NettyTcpClient<String> getTcpClient(org.thales.punch.settings.api.ISettingsMap settings,
                                                  org.thales.punch.libraries.metrics.api.IMetricContext metricsContext,
                                                  NettyDataAcker acker)

Parameters:

settings - all the required settings

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

acker - the data acker, should this client receive acknowledgements

Returns:

a netty based TCP client.

getLumberjackClient

public static NettyTcpClient<Map<String,String>> getLumberjackClient(org.thales.punch.settings.api.ISettingsMap settings,
                                                                     org.thales.punch.libraries.metrics.api.IMetricContext metricsContext,
                                                                     NettyDataAcker acker)

Return a TCP client.

Parameters:

settings - the user settings

metricsContext - the associated metrics context

acker - the data acker, should this client receive acknowledgements

Returns:

the client

getUdpClient

public static NettyUdpClient getUdpClient(org.thales.punch.settings.api.ISettingsMap settings,
                                          org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)
                                   throws IOException

Return a UDP client. Return a Line based TCP server.

Parameters:

settings - the user settings

metricsContext - the metrics context

Returns:

the client

Throws:

IOException

UnknownHostException

getHttpClient

public static NettyHttpClientImpl getHttpClient(org.thales.punch.settings.api.ISettingsMap settings,
                                                org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Returns a HTTP client.

Parameters:

settings - all the required settings

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

Returns:

a netty based TCP client.

getHttpClient

public static NettyHttpClientImpl getHttpClient(org.thales.punch.settings.api.ISettingsMap settings,
                                                org.thales.punch.libraries.metrics.api.IMetricContext metricsContext,
                                                NettyDataAcker acker)

Returns a HTTP client.

Parameters:

settings - all the required settings

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

acker - the data acker, should this client receive acknowledgements

Returns:

a netty based TCP client.

getTcpServer

public static <T> NettySocketServer<T> getTcpServer(org.thales.punch.settings.api.ISettingsMap settings,
                                                    org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Return a Line based TCP server.

Parameters:

settings - the user settings

metricsContext -

Returns:

the server

getSnmpServer

public static NettySocketServer<String> getSnmpServer(org.thales.punch.settings.api.ISettingsMap settings,
                                                      org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Return a Line based TCP server.

Parameters:

settings - the user settings

metricsContext -

Returns:

the server

getRelpServer

public static NettySocketServer<RELPFrame> getRelpServer(org.thales.punch.settings.api.ISettingsMap settings,
                                                         org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Return a plain TCP server.

Parameters:

settings - the server settings

metricsContext - the associated metrics context

Returns:

the server

getTcpLumberjackServer

public static NettySocketServer<Map<String,String>> getTcpLumberjackServer(org.thales.punch.settings.api.ISettingsMap settings,
                                                                           org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Return a TCP Lumberjack Server server.

Parameters:

settings - the user settings

metricsContext - the associated metrics context

Returns:

the server

getHttpServer

public static NettySocketServer<Map<String,Object>> getHttpServer(org.thales.punch.settings.api.ISettingsMap settings,
                                                                  org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Return an HTTP server.

Parameters:

settings - the user settings

metricsContext - the associated metrics context

Returns:

the server

getUdpServer

public static <T> NettySocketServer<T> getUdpServer(org.thales.punch.settings.api.ISettingsMap settings,
                                                    org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Return a TCP server.

Parameters:

settings - the user settings

metricsContext - the associated metrics context

Returns:

the server

getServer

public static NettySocketServer<String> getServer(org.thales.punch.settings.api.ISettingsMap settings,
                                                  org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Return a line based UDP or TCP server. If you use TCP protocol it will read in '\n' terminated lines.

Parameters:

settings - your configuration with listening addresses, codecs, etc ...

metricsContext - the associated metrics context

Returns:

the server