biz.paluch.logging.gelf.intern.sender

Class AbstractNioSender<T extends AbstractSelectableChannel & ByteChannel>

java.lang.Object

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

Type Parameters:

T - must by AbstractSelectableChannel and ByteChannel.

All Implemented Interfaces:

ErrorReporter

Direct Known Subclasses:

GelfTCPSender, GelfUDPSender

public abstract class AbstractNioSender<T extends AbstractSelectableChannel & ByteChannel>
extends Object
implements ErrorReporter

Base class for NIO-channel senders.

Since:

1.11

Author:

Mark Paluch

Field Summary

Fields

Modifier and Type	Field and Description
static int	INITIAL_BUFFER_SIZE Default initial buffer size 40 x 8192.
static String	PROPERTY_BUFFER_SIZE Buffer size for transmit buffers.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractNioSender(ErrorReporter errorReporter, String host, int port) Create a new AbstractNioSender given ErrorReporter, host and port.

Method Summary

Modifier and Type	Method and Description
protected T	channel()
void	close()
String	getHost()
int	getPort()
protected boolean	isConnected()
protected abstract boolean	isConnected(T channel)
boolean	isShutdown()
void	reportError(String message, Exception e) Report an error caused by a exception.
void	setChannel(T channel)

Methods inherited from class java.lang.Object

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

Field Detail

PROPERTY_BUFFER_SIZE

public static final String PROPERTY_BUFFER_SIZE

Buffer size for transmit buffers. Defaults to 99 * 8192

See Also:

Constant Field Values

INITIAL_BUFFER_SIZE

public static final int INITIAL_BUFFER_SIZE

Default initial buffer size 40 x 8192.

Constructor Detail

AbstractNioSender

protected AbstractNioSender(ErrorReporter errorReporter,
                            String host,
                            int port)
                     throws UnknownHostException

Create a new AbstractNioSender given ErrorReporter, host and port. Object creation triggers hostname lookup for early failure.

Parameters:

errorReporter - the error reporter.

host - hostname.

port - port number.

Throws:

UnknownHostException - if no IP address for the host could be found, or if a scope_id was specified for a global IPv6 address.

Method Detail

isConnected

protected boolean isConnected()
                       throws IOException

Throws:

IOException

isConnected

protected abstract boolean isConnected(T channel)

channel

protected T channel()

getHost

public String getHost()

getPort

public int getPort()

close

public void close()

isShutdown

public boolean isShutdown()

reportError

public void reportError(String message,
                        Exception e)

Description copied from interface: ErrorReporter

Report an error caused by a exception.

Specified by:

reportError in interface ErrorReporter

Parameters:

message - the message

e - the exception

setChannel

public void setChannel(T channel)