org.opennms.netmgt.syslogd

Class SyslogConnection

java.lang.Object

org.opennms.netmgt.syslogd.SyslogConnection

All Implemented Interfaces:

Callable<Callable<?>>

public class SyslogConnection
extends Object
implements Callable<Callable<?>>

This class is a Callable task that is responsible for converting the syslog payload into an OpenNMS event by using the ConvertToEvent class.

Author:

Mathew Brozowski, Johan Edstrom, Mike Huot

Constructor Summary

Constructors

Constructor and Description
SyslogConnection() No-arg constructor so that we can preallocate this object for use with an LMAX Disruptor or use it with JAXB.
SyslogConnection(DatagramPacket packet, SyslogdConfig config)
SyslogConnection(InetAddress sourceAddress, int port, ByteBuffer bytes, SyslogdConfig config)

Method Summary

Modifier and Type	Method and Description
SyslogProcessor	call()
static DatagramPacket	copyPacket(InetAddress sourceAddress, int sourcePort, ByteBuffer buffer)
ByteBuffer	getByteBuffer()
byte[]	getBytes()
SyslogdConfig	getConfig()
int	getPort()
InetAddress	getSourceAddress()
void	setByteBuffer(ByteBuffer bytes)
void	setBytes(byte[] bytes)
void	setConfig(SyslogdConfig config)
void	setPort(int port)
void	setSourceAddress(InetAddress sourceAddress)

Methods inherited from class java.lang.Object

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

Constructor Detail

SyslogConnection

public SyslogConnection()

No-arg constructor so that we can preallocate this object for use with an LMAX Disruptor or use it with JAXB.

SyslogConnection

public SyslogConnection(DatagramPacket packet,
                        SyslogdConfig config)

SyslogConnection

public SyslogConnection(InetAddress sourceAddress,
                        int port,
                        ByteBuffer bytes,
                        SyslogdConfig config)

Method Detail

getSourceAddress

public InetAddress getSourceAddress()

setSourceAddress

public void setSourceAddress(InetAddress sourceAddress)

getPort

public int getPort()

setPort

public void setPort(int port)

getByteBuffer

public ByteBuffer getByteBuffer()

setByteBuffer

public void setByteBuffer(ByteBuffer bytes)

getBytes

public byte[] getBytes()

setBytes

public void setBytes(byte[] bytes)

getConfig

public SyslogdConfig getConfig()

setConfig

public void setConfig(SyslogdConfig config)

call

public SyslogProcessor call()

Specified by:

call in interface Callable<Callable<?>>

copyPacket

public static DatagramPacket copyPacket(InetAddress sourceAddress,
                                        int sourcePort,
                                        ByteBuffer buffer)