org.graylog2.syslog4j.impl.net.tcp

Class TCPNetSyslogWriter

java.lang.Object

org.graylog2.syslog4j.impl.AbstractSyslogWriter

org.graylog2.syslog4j.impl.net.tcp.TCPNetSyslogWriter

All Implemented Interfaces:

Serializable, Runnable

Direct Known Subclasses:

SSLTCPNetSyslogWriter

public class TCPNetSyslogWriter
extends AbstractSyslogWriter

TCPNetSyslogWriter is an implementation of Runnable that supports sending TCP-based messages within a separate Thread.

When used in "threaded" mode (see TCPNetSyslogConfig for the option), a queuing mechanism is used (via LinkedList).

Syslog4j is licensed under the Lesser GNU Public License v2.1. A copy of the LGPL license is available in the META-INF folder in all distributions of Syslog4j and in the base directory of the "doc" ZIP.

Version:

$Id: TCPNetSyslogWriter.java,v 1.20 2010/11/28 01:38:08 cvs Exp $

Author:

<syslog4j@productivity.org>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected long	lastSocketCreationTimeMs
protected Socket	socket
protected TCPNetSyslog	tcpNetSyslog
protected TCPNetSyslogConfigIF	tcpNetSyslogConfig

Fields inherited from class org.graylog2.syslog4j.impl.AbstractSyslogWriter

queuedMessages, shutdown, syslog, syslogConfig, thread

Constructor Summary

Constructors

Constructor and Description
TCPNetSyslogWriter()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	closeSocket(Socket socketToClose)
protected Socket	createSocket(InetAddress hostAddress, int port, boolean keepalive)
void	flush()
protected Socket	getSocket()
void	initialize(AbstractSyslog abstractSyslog)
protected SocketFactory	obtainSocketFactory()
protected void	runCompleted()
void	shutdown()
void	write(byte[] message)

Methods inherited from class org.graylog2.syslog4j.impl.AbstractSyslogWriter

hasThread, queue, run, setThread

Methods inherited from class java.lang.Object

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

Field Detail

tcpNetSyslog

protected TCPNetSyslog tcpNetSyslog

socket

protected Socket socket

tcpNetSyslogConfig

protected TCPNetSyslogConfigIF tcpNetSyslogConfig

lastSocketCreationTimeMs

protected long lastSocketCreationTimeMs

Constructor Detail

TCPNetSyslogWriter

public TCPNetSyslogWriter()

Method Detail

initialize

public void initialize(AbstractSyslog abstractSyslog)

Overrides:

initialize in class AbstractSyslogWriter

obtainSocketFactory

protected SocketFactory obtainSocketFactory()

createSocket

protected Socket createSocket(InetAddress hostAddress,
                  int port,
                  boolean keepalive)
                       throws IOException

Throws:

IOException

getSocket

protected Socket getSocket()
                    throws SyslogRuntimeException

Throws:

SyslogRuntimeException

closeSocket

protected void closeSocket(Socket socketToClose)

write

public void write(byte[] message)
           throws SyslogRuntimeException

Specified by:

write in class AbstractSyslogWriter

Throws:

SyslogRuntimeException

flush

public void flush()
           throws SyslogRuntimeException

Specified by:

flush in class AbstractSyslogWriter

Throws:

SyslogRuntimeException

shutdown

public void shutdown()
              throws SyslogRuntimeException

Specified by:

shutdown in class AbstractSyslogWriter

Throws:

SyslogRuntimeException

runCompleted

protected void runCompleted()

Specified by:

runCompleted in class AbstractSyslogWriter