Package 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 java.lang.Object implements MessageConsumer<SyslogConnection,SyslogMessageLogDTO>, org.springframework.beans.factory.InitializingBean
-
-
Constructor Summary
Constructors Constructor Description SyslogSinkConsumer(com.codahale.metrics.MetricRegistry registry)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
afterPropertiesSet()
SyslogSinkModule
getModule()
void
handleMessage(SyslogMessageLogDTO syslogDTO)
void
setDistPollerDao(DistPollerDao distPollerDao)
void
setEventForwarder(EventForwarder eventForwarder)
void
setLocationAwareDnsLookupClient(LocationAwareDnsLookupClient locationAwareDnsLookupClient)
void
setMessageConsumerManager(MessageConsumerManager messageConsumerManager)
void
setSyslogdConfig(SyslogdConfig syslogdConfig)
Log
toEventLog(SyslogMessageLogDTO messageLog)
-
-
-
Method Detail
-
getModule
public SyslogSinkModule getModule()
- Specified by:
getModule
in interfaceMessageConsumer<SyslogConnection,SyslogMessageLogDTO>
-
handleMessage
public void handleMessage(SyslogMessageLogDTO syslogDTO)
- Specified by:
handleMessage
in interfaceMessageConsumer<SyslogConnection,SyslogMessageLogDTO>
-
toEventLog
public Log toEventLog(SyslogMessageLogDTO messageLog)
-
afterPropertiesSet
public void afterPropertiesSet() throws java.lang.Exception
- Specified by:
afterPropertiesSet
in interfaceorg.springframework.beans.factory.InitializingBean
- Throws:
java.lang.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)
-
setLocationAwareDnsLookupClient
public void setLocationAwareDnsLookupClient(LocationAwareDnsLookupClient locationAwareDnsLookupClient)
-
-