org.thales.punch.netty.impl

Class NettyAbstractEndpoint

java.lang.Object

org.thales.punch.netty.impl.NettyAbstractEndpoint

Direct Known Subclasses:

NettyAbstractClient, NettyAbstractServer

public abstract class NettyAbstractEndpoint
extends Object

Netty endpoints (server or client) use many shared configuration items. These are regrouped here.

Author:

dimi

Field Summary

Fields

Modifier and Type	Field and Description
protected io.netty.bootstrap.Bootstrap	bootstrap our netty client bootstrap.
protected String	host The listening or destination host host ip address.
protected int	maxPayloadLength max allowed length
protected org.thales.punch.libraries.metrics.api.IMetricContext	metricsContext our injected metrics context
protected int	port The listening or destination port
protected String	protocol The listening or destination host host ip address.
protected String	readSocketTimeoutAction what to do if the timeout occurs
protected long	readSocketTimeoutMs timeout if no data is read for this amount of seconds
protected boolean	ssl use ssl.
protected List<String>	sslCiphers default ciphers used by endpoints
protected String	sslProtocol protocol to use for ssl
protected String	sslProvider ssl provider to use : JDK, OPENSSL or OPENSSL_REFCNT
protected boolean	useNettyCompression use compression at the socket level

Constructor Summary

Constructors

Constructor and Description
NettyAbstractEndpoint(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Method Summary

Modifier and Type	Method and Description
static File	getFileFromString(String content) Fail stop method to create a temporary file from a string content.
protected io.netty.handler.ssl.SslProvider	getSslProvider(String sslProvider) Retrieve the sslPorvider class from the name.

Methods inherited from class java.lang.Object

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

Field Detail

protocol

protected String protocol

The listening or destination host host ip address.

host

protected String host

The listening or destination host host ip address.

port

protected int port

The listening or destination port

readSocketTimeoutMs

protected long readSocketTimeoutMs

timeout if no data is read for this amount of seconds

readSocketTimeoutAction

protected String readSocketTimeoutAction

what to do if the timeout occurs

useNettyCompression

protected boolean useNettyCompression

use compression at the socket level

ssl

protected boolean ssl

use ssl.

maxPayloadLength

protected int maxPayloadLength

max allowed length

bootstrap

protected io.netty.bootstrap.Bootstrap bootstrap

our netty client bootstrap.

metricsContext

protected org.thales.punch.libraries.metrics.api.IMetricContext metricsContext

our injected metrics context

sslProtocol

protected String sslProtocol

protocol to use for ssl

sslProvider

protected String sslProvider

ssl provider to use : JDK, OPENSSL or OPENSSL_REFCNT

sslCiphers

protected List<String> sslCiphers

default ciphers used by endpoints

Constructor Detail

NettyAbstractEndpoint

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

Method Detail

getSslProvider

protected io.netty.handler.ssl.SslProvider getSslProvider(String sslProvider)

Retrieve the sslPorvider class from the name. Three types are available : JDK, OPENSSL and OPENSSL_REFCNT

Parameters:

sslProvider - the ssl provider name

Returns:

SslProvider class

getFileFromString

public static File getFileFromString(String content)

Fail stop method to create a temporary file from a string content.

Parameters:

content -

Returns:

a temporary file holding the content of the certificate