org.opennms.netmgt.syslogd

Class SyslogSinkConsumer

java.lang.Object

org.opennms.netmgt.syslogd.SyslogSinkConsumer

All Implemented Interfaces:

MessageConsumer<SyslogConnection,SyslogMessageLogDTO>, org.springframework.beans.factory.InitializingBean

public class SyslogSinkConsumer
extends Object
implements MessageConsumer<SyslogConnection,SyslogMessageLogDTO>, org.springframework.beans.factory.InitializingBean

Constructor Summary

Constructors

Constructor and Description
SyslogSinkConsumer(com.codahale.metrics.MetricRegistry registry)

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
SyslogSinkModule	getModule()
void	handleMessage(SyslogMessageLogDTO syslogDTO)
void	setDistPollerDao(DistPollerDao distPollerDao)
void	setEventForwarder(EventForwarder eventForwarder)
void	setMessageConsumerManager(MessageConsumerManager messageConsumerManager)
void	setSyslogdConfig(SyslogdConfig syslogdConfig)
Log	toEventLog(SyslogMessageLogDTO messageLog)

Methods inherited from class java.lang.Object

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

Constructor Detail

SyslogSinkConsumer

public SyslogSinkConsumer(com.codahale.metrics.MetricRegistry registry)

Method Detail

getModule

public SyslogSinkModule getModule()

Specified by:

getModule in interface MessageConsumer<SyslogConnection,SyslogMessageLogDTO>

handleMessage

public void handleMessage(SyslogMessageLogDTO syslogDTO)

Specified by:

handleMessage in interface MessageConsumer<SyslogConnection,SyslogMessageLogDTO>

toEventLog

public Log toEventLog(SyslogMessageLogDTO messageLog)

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

setEventForwarder

public void setEventForwarder(EventForwarder eventForwarder)

setMessageConsumerManager

public void setMessageConsumerManager(MessageConsumerManager messageConsumerManager)

setSyslogdConfig

public void setSyslogdConfig(SyslogdConfig syslogdConfig)

setDistPollerDao

public void setDistPollerDao(DistPollerDao distPollerDao)