org.thales.punch.netty.impl

Class NettyAbstractClient

java.lang.Object

org.thales.punch.netty.impl.NettyAbstractEndpoint

org.thales.punch.netty.impl.NettyAbstractClient

Direct Known Subclasses:

NettyHttpClientImpl, NettyLumberJackClientImpl, NettyTcpClientImpl

public abstract class NettyAbstractClient
extends NettyAbstractEndpoint

The NIO client sends out events as string on a tcp socket.

It uses a single socket towards the destination. That socket is created and connected whenever the first message is sent, or after the socket was closed by the peer.

This output is blocking, that is, if the peer is slow, this output will hang so that the peer can catch up. This makes this output's input queue grow and accumulate messages.

Author:

dimi

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	raw dont add any '\n' at the end of Strings

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
NettyAbstractClient(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Common constructor for all clients.

Method Summary

Modifier and Type	Method and Description
protected io.netty.channel.Channel	connect(AtomicBoolean connected) connect to the server.
long	getConnectIntervalMs()
long	getConnectRetryIntervalMs()
io.netty.handler.ssl.SslContext	getSslContext() Return the ssl context associated to this client.
void	setConnectIntervalMs(long connectIntervalMs) Set the connection interval
void	setConnectRetryIntervalMs(long connectRetryIntervalMs) Set the connection retry interval
protected void	shutdown()

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, toString, wait, wait, wait

Field Detail

raw

protected boolean raw

dont add any '\n' at the end of Strings

Constructor Detail

NettyAbstractClient

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

Common constructor for all clients.

Parameters:

settings -

metricsContext -

Method Detail

getConnectRetryIntervalMs

public long getConnectRetryIntervalMs()

Returns:

the connect retry interval

setConnectRetryIntervalMs

public void setConnectRetryIntervalMs(long connectRetryIntervalMs)

Set the connection retry interval

Parameters:

connectRetryIntervalMs - the new interval

getConnectIntervalMs

public long getConnectIntervalMs()

Returns:

the connection interval

setConnectIntervalMs

public void setConnectIntervalMs(long connectIntervalMs)

Set the connection interval

Parameters:

connectIntervalMs - the new interval

getSslContext

public io.netty.handler.ssl.SslContext getSslContext()

Return the ssl context associated to this client.

Returns:

the ssl context or null if no ssl is set up.

connect

protected io.netty.channel.Channel connect(AtomicBoolean connected)

connect to the server. This method is blocking.

Parameters:

connected -

Returns:

a connected channel or null if the connection timeout.

shutdown

protected void shutdown()