Package org.openehealth.ipf.commons.audit.protocol

Class ReactorNettyTLSSyslogSenderImpl

java.lang.Object

org.openehealth.ipf.commons.audit.protocol.RFC5424Protocol

org.openehealth.ipf.commons.audit.protocol.RFC5425Protocol

org.openehealth.ipf.commons.audit.protocol.NioTLSSyslogSenderImpl<reactor.netty.Connection,ReactorNettyTLSSyslogSenderImpl.ReactorNettyDestination>

org.openehealth.ipf.commons.audit.protocol.ReactorNettyTLSSyslogSenderImpl

All Implemented Interfaces:

AuditTransmissionProtocol

public class ReactorNettyTLSSyslogSenderImpl
extends NioTLSSyslogSenderImpl<reactor.netty.Connection,ReactorNettyTLSSyslogSenderImpl.ReactorNettyDestination>

Reactor Netty client implementation of RFC 5425 TLS syslog transport for sending audit messages to an Audit Record Repository that implements TLS syslog. Multiple messages may be sent over the same socket.

Since:

4.0

Author:

Christian Ohr

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ReactorNettyTLSSyslogSenderImpl.ReactorNettyDestination	Destination abstraction for Netty

Nested classes/interfaces inherited from class org.openehealth.ipf.commons.audit.protocol.NioTLSSyslogSenderImpl

NioTLSSyslogSenderImpl.Destination<H>

Field Summary

Fields inherited from interface org.openehealth.ipf.commons.audit.protocol.AuditTransmissionProtocol

HTTPS_CIPHERSUITES, JAVAX_NET_DEBUG, JAVAX_NET_SSL_KEYSTORE, JAVAX_NET_SSL_KEYSTORE_PASSWORD, JAVAX_NET_SSL_KEYSTORE_TYPE, JAVAX_NET_SSL_TRUSTSTORE, JAVAX_NET_SSL_TRUSTSTORE_PASSWORD, JAVAX_NET_SSL_TRUSTSTORE_TYPE, JAVAX_TLS_CLIENT_CIPHERSUITES, JAVAX_TLS_SERVER_CIPHERSUITES, JDK_TLS_CLIENT_PROTOCOLS

Constructor Summary

Constructors

Constructor	Description
ReactorNettyTLSSyslogSenderImpl(TlsParameters tlsParameters)

Method Summary

Modifier and Type	Method	Description
String	getTransportName()
protected ReactorNettyTLSSyslogSenderImpl.ReactorNettyDestination	makeDestination(TlsParameters tlsParameters, String host, int port, boolean logging)
void	setConnectTimeout(int value, TimeUnit timeUnit)	Sets the connect timeout
void	setSendTimeout(int value, TimeUnit timeUnit)	Sets the send timeout
void	setWorkerThreads(int workerThreads)	Set the number of working threads.

Methods inherited from class org.openehealth.ipf.commons.audit.protocol.NioTLSSyslogSenderImpl

customizeDestination, send, setLoggingEnabled, shutdown

Methods inherited from class org.openehealth.ipf.commons.audit.protocol.RFC5425Protocol

getTransportPayload

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openehealth.ipf.commons.audit.protocol.AuditTransmissionProtocol

send

Constructor Details

ReactorNettyTLSSyslogSenderImpl

public ReactorNettyTLSSyslogSenderImpl(TlsParameters tlsParameters)

Method Details

getTransportName

public String getTransportName()

Returns:

name of the AuditTransmissionProtocol

makeDestination

protected ReactorNettyTLSSyslogSenderImpl.ReactorNettyDestination makeDestination(TlsParameters tlsParameters,
 String host,
 int port,
 boolean logging)

Specified by:

makeDestination in class NioTLSSyslogSenderImpl<reactor.netty.Connection,ReactorNettyTLSSyslogSenderImpl.ReactorNettyDestination>

setConnectTimeout

public void setConnectTimeout(int value,
 TimeUnit timeUnit)

Sets the connect timeout

Parameters:

value - time value

timeUnit - time unit

setSendTimeout

public void setSendTimeout(int value,
 TimeUnit timeUnit)

Sets the send timeout

Parameters:

value - time value

timeUnit - time unit

setWorkerThreads

public void setWorkerThreads(int workerThreads)

Set the number of working threads. This corresponds with the number of connections being opened. Defaults to 1.

Parameters:

workerThreads - number of worker threads.