biz.paluch.logging.gelf.intern.sender

Class GelfTCPSender

java.lang.Object

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

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

All Implemented Interfaces:

ErrorReporter, GelfSender, Closeable, AutoCloseable

Direct Known Subclasses:

GelfTCPSSLSender

public class GelfTCPSender
extends AbstractNioSender<SocketChannel>
implements GelfSender

Author:

https://github.com/t0xa/gelfj, Mark Paluch

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONNECTION_TIMEOUT
static String	KEEPALIVE
static String	MAX_WRITE_BACKOFF_TIME
static String	READ_TIMEOUT
static String	RETRIES
static String	WRITE_BACKOFF_THRESHOLD
static String	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
GelfTCPSender(String host, int port, int connectTimeoutMs, int readTimeoutMs, ErrorReporter errorReporter)
GelfTCPSender(String host, int port, int connectTimeoutMs, int readTimeoutMs, int deliveryAttempts, boolean keepAlive, biz.paluch.logging.gelf.intern.sender.BackOff backoff, int writeBackoffThreshold, ErrorReporter errorReporter)
GelfTCPSender(String host, int port, int connectTimeoutMs, int readTimeoutMs, int deliveryAttempts, boolean keepAlive, ErrorReporter errorReporter)

Method Summary

Modifier and Type	Method and Description
protected boolean	connect()
protected SocketChannel	createSocketChannel(int readTimeoutMs, boolean keepAlive)
protected boolean	isConnected(SocketChannel channel)
boolean	sendMessage(GelfMessage message) Send the Gelf message.
protected void	write(ByteBuffer buffer)

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

channel, close, getHost, getPort, isConnected, isShutdown, reportError, setChannel

Methods inherited from class java.lang.Object

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

Methods inherited from interface biz.paluch.logging.gelf.intern.GelfSender

close

Field Detail

CONNECTION_TIMEOUT

public static final String CONNECTION_TIMEOUT

See Also:

Constant Field Values

READ_TIMEOUT

public static final String READ_TIMEOUT

See Also:

Constant Field Values

RETRIES

public static final String RETRIES

See Also:

Constant Field Values

KEEPALIVE

public static final String KEEPALIVE

See Also:

Constant Field Values

WRITE_BACKOFF_TIME

public static final String WRITE_BACKOFF_TIME

See Also:

Constant Field Values

WRITE_BACKOFF_THRESHOLD

public static final String WRITE_BACKOFF_THRESHOLD

See Also:

Constant Field Values

MAX_WRITE_BACKOFF_TIME

public static final String MAX_WRITE_BACKOFF_TIME

See Also:

Constant Field Values

Constructor Detail

GelfTCPSender

public GelfTCPSender(String host,
                     int port,
                     int connectTimeoutMs,
                     int readTimeoutMs,
                     ErrorReporter errorReporter)
              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.

errorReporter - the error reporter, must not be null.

Throws:

IOException - in case of I/O errors

GelfTCPSender

public GelfTCPSender(String host,
                     int port,
                     int connectTimeoutMs,
                     int readTimeoutMs,
                     int deliveryAttempts,
                     boolean keepAlive,
                     ErrorReporter errorReporter)
              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.

Throws:

IOException - in case of I/O errors

GelfTCPSender

public GelfTCPSender(String host,
                     int port,
                     int connectTimeoutMs,
                     int readTimeoutMs,
                     int deliveryAttempts,
                     boolean keepAlive,
                     biz.paluch.logging.gelf.intern.sender.BackOff backoff,
                     int writeBackoffThreshold,
                     ErrorReporter errorReporter)
              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.

Throws:

IOException - in case of I/O errors

Method Detail

createSocketChannel

protected SocketChannel createSocketChannel(int readTimeoutMs,
                                            boolean keepAlive)
                                     throws IOException

Throws:

IOException

sendMessage

public boolean sendMessage(GelfMessage message)

Description copied from interface: GelfSender

Send the Gelf message.

Specified by:

sendMessage in interface GelfSender

Parameters:

message - the message

Returns:

true if message was sent.

write

protected void write(ByteBuffer buffer)
              throws IOException,
                     InterruptedException

Throws:

IOException

InterruptedException

connect

protected boolean connect()
                   throws IOException

Throws:

IOException

isConnected

protected boolean isConnected(SocketChannel channel)

Specified by:

isConnected in class AbstractNioSender<SocketChannel>