org.opennms.netmgt.syslogd

Class SyslogReceiverNioThreadPoolImpl

java.lang.Object

org.opennms.netmgt.syslogd.SyslogReceiverNioThreadPoolImpl

All Implemented Interfaces:

Runnable, SyslogReceiver

public class SyslogReceiverNioThreadPoolImpl
extends Object
implements SyslogReceiver

Author:

Seth, Brian Weaver, Oculan Corporation

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_PACKET_SIZE This size is used as the size of each ByteBuffer used to capture syslog messages.
static int	SOCKET_RECEIVER_COUNT This is the number of NIO listener threads that will process DatagramChannel.receive(ByteBuffer) calls on the syslog port.

Constructor Summary

Constructors

Constructor and Description
SyslogReceiverNioThreadPoolImpl(SyslogdConfig config) Construct a new receiver

Method Summary

Modifier and Type	Method and Description
String	getName()
SyslogConnectionHandler	getSyslogConnectionHandlers()
static DatagramChannel	openChannel(SyslogdConfig config)
void	run() The execution context.
void	setSyslogConnectionHandlers(SyslogConnectionHandler handler)
void	stop() stop the current receiver

Methods inherited from class java.lang.Object

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

Field Detail

MAX_PACKET_SIZE

public static final int MAX_PACKET_SIZE

This size is used as the size of each ByteBuffer used to capture syslog messages.

See Also:

Constant Field Values

SOCKET_RECEIVER_COUNT

public static final int SOCKET_RECEIVER_COUNT

This is the number of NIO listener threads that will process DatagramChannel.receive(ByteBuffer) calls on the syslog port.

Constructor Detail

SyslogReceiverNioThreadPoolImpl

public SyslogReceiverNioThreadPoolImpl(SyslogdConfig config)
                                throws SocketException,
                                       IOException

Construct a new receiver

Parameters:

sock -

matchPattern -

hostGroup -

messageGroup -

Throws:

SocketException

IOException

Method Detail

openChannel

public static DatagramChannel openChannel(SyslogdConfig config)
                                   throws SocketException,
                                          IOException

Throws:

SocketException

IOException

getName

public String getName()

Specified by:

getName in interface SyslogReceiver

stop

public void stop()
          throws InterruptedException

stop the current receiver

Specified by:

stop in interface SyslogReceiver

Throws:

InterruptedException

getSyslogConnectionHandlers

public SyslogConnectionHandler getSyslogConnectionHandlers()

setSyslogConnectionHandlers

public void setSyslogConnectionHandlers(SyslogConnectionHandler handler)

run

public void run()

The execution context.

Specified by:

run in interface Runnable

Specified by:

run in interface SyslogReceiver