public abstract class SinkDispatchingSyslogReceiver extends Object implements SyslogReceiver
Modifier and Type | Field and Description |
---|---|
protected AsyncDispatcher<SyslogConnection> |
m_dispatcher |
Constructor and Description |
---|
SinkDispatchingSyslogReceiver(SyslogdConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
run() |
void |
setDistPollerDao(DistPollerDao distPollerDao) |
void |
setMessageDispatcherFactory(MessageDispatcherFactory messageDispatcherFactory) |
void |
stop() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getName, reload
protected AsyncDispatcher<SyslogConnection> m_dispatcher
public SinkDispatchingSyslogReceiver(SyslogdConfig config)
public void run()
run
in interface Runnable
run
in interface SyslogReceiver
public void stop() throws InterruptedException
stop
in interface SyslogReceiver
InterruptedException
public void setDistPollerDao(DistPollerDao distPollerDao)
public void setMessageDispatcherFactory(MessageDispatcherFactory messageDispatcherFactory)
Copyright © 2021. All rights reserved.