biz.paluch.logging.gelf.intern.sender

Class GelfTCPSSLSender

java.lang.Object

biz.paluch.logging.gelf.intern.sender.AbstractNioSender<SocketChannel>

biz.paluch.logging.gelf.intern.sender.GelfTCPSender

biz.paluch.logging.gelf.intern.sender.GelfTCPSSLSender

All Implemented Interfaces:

ErrorReporter, GelfSender, Closeable, AutoCloseable

public class GelfTCPSSLSender
extends GelfTCPSender

TCP with SSL GelfSender.

Since:

1.11

Author:

Mark Paluch, Alexander Katanov

Field Summary

Fields inherited from class biz.paluch.logging.gelf.intern.sender.GelfTCPSender

CONNECTION_TIMEOUT, KEEPALIVE, MAX_WRITE_BACKOFF_TIME, READ_TIMEOUT, RETRIES, WRITE_BACKOFF_THRESHOLD, WRITE_BACKOFF_TIME

Fields inherited from class biz.paluch.logging.gelf.intern.sender.AbstractNioSender

INITIAL_BUFFER_SIZE, PROPERTY_BUFFER_SIZE

Constructor Summary

Constructors

Constructor and Description
GelfTCPSSLSender(String host, int port, int connectTimeoutMs, int readTimeoutMs, int deliveryAttempts, boolean keepAlive, biz.paluch.logging.gelf.intern.sender.BackOff backoff, int writeBackoffThreshold, ErrorReporter errorReporter, SSLContext sslContext)
GelfTCPSSLSender(String host, int port, int connectTimeoutMs, int readTimeoutMs, int deliveryAttempts, boolean keepAlive, ErrorReporter errorReporter, SSLContext sslContext)

Method Summary

Modifier and Type	Method and Description
void	close() Close the sender and free resources.
protected boolean	connect()
protected boolean	isConnected()
protected boolean	isConnected(SocketChannel channel)
protected void	write(ByteBuffer gelfBuffer)

Methods inherited from class biz.paluch.logging.gelf.intern.sender.GelfTCPSender

createSocketChannel, sendMessage

Methods inherited from class biz.paluch.logging.gelf.intern.sender.AbstractNioSender

channel, getHost, getPort, isShutdown, reportError, setChannel

Methods inherited from class java.lang.Object

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

Constructor Detail

GelfTCPSSLSender

public GelfTCPSSLSender(String host,
                        int port,
                        int connectTimeoutMs,
                        int readTimeoutMs,
                        int deliveryAttempts,
                        boolean keepAlive,
                        ErrorReporter errorReporter,
                        SSLContext sslContext)
                 throws IOException

Parameters:

host - the host, must not be null.

port - the port.

connectTimeoutMs - connection timeout, in TimeUnit.MILLISECONDS.

readTimeoutMs - read timeout, in TimeUnit.MILLISECONDS.

deliveryAttempts - number of delivery attempts.

keepAlive - true to enable TCP keep-alive.

errorReporter - the error reporter, must not be null.

sslContext - the SSL context, must not be null.

Throws:

IOException - in case of I/O errors

GelfTCPSSLSender

public GelfTCPSSLSender(String host,
                        int port,
                        int connectTimeoutMs,
                        int readTimeoutMs,
                        int deliveryAttempts,
                        boolean keepAlive,
                        biz.paluch.logging.gelf.intern.sender.BackOff backoff,
                        int writeBackoffThreshold,
                        ErrorReporter errorReporter,
                        SSLContext sslContext)
                 throws IOException

Parameters:

host - the host, must not be null.

port - the port.

connectTimeoutMs - connection timeout, in TimeUnit.MILLISECONDS.

readTimeoutMs - read timeout, in TimeUnit.MILLISECONDS.

deliveryAttempts - number of delivery attempts.

keepAlive - true to enable TCP keep-alive.

backoff - Backoff strategy to activate if a socket sender buffer is full and several attempts to write to the socket are unsuccessful due to it.

writeBackoffThreshold - attempts to write to a socket before a backoff will be activated.

errorReporter - the error reporter, must not be null.

sslContext - the SSL context, must not be null.

Throws:

IOException - in case of I/O errors

Method Detail

connect

protected boolean connect()
                   throws IOException

Overrides:

connect in class GelfTCPSender

Throws:

IOException

isConnected

protected boolean isConnected()
                       throws IOException

Overrides:

isConnected in class AbstractNioSender<SocketChannel>

Throws:

IOException

write

protected void write(ByteBuffer gelfBuffer)
              throws IOException

Overrides:

write in class GelfTCPSender

Throws:

IOException

close

public void close()

Description copied from interface: GelfSender

Close the sender and free resources.

Specified by:

close in interface GelfSender

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractNioSender<SocketChannel>

isConnected

protected boolean isConnected(SocketChannel channel)

Overrides:

isConnected in class GelfTCPSender