public class SyslogSinkModule extends AbstractXmlSinkModule<SyslogConnection,SyslogMessageLogDTO>
Constructor and Description |
---|
SyslogSinkModule(SyslogdConfig config,
DistPollerDao distPollerDao) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
AggregationPolicy<SyslogConnection,SyslogMessageLogDTO> |
getAggregationPolicy()
Defines how messages should be combined, and when they
should be "released".
|
AsyncPolicy |
getAsyncPolicy()
Defines how messages should be asynchronously dispatched.
|
String |
getId()
Globally unique identifier.
|
int |
getNumConsumerThreads()
The number of threads used to consume from the broker.
|
int |
hashCode() |
SyslogMessageLogDTO |
toMessageLog(SyslogConnection... connections)
Used for testing.
|
marshal, unmarshal
public static final String MODULE_ID
public SyslogSinkModule(SyslogdConfig config, DistPollerDao distPollerDao)
public String getId()
SinkModule
public int getNumConsumerThreads()
SinkModule
public AggregationPolicy<SyslogConnection,SyslogMessageLogDTO> getAggregationPolicy()
SinkModule
null
.AggregationPolicy
used to combine messages, or null
if the messages should not be combined.public AsyncPolicy getAsyncPolicy()
SinkModule
AsyncPolicy
used when asynchronously dispatching
messages for this module.public SyslogMessageLogDTO toMessageLog(SyslogConnection... connections)
public int hashCode()
hashCode
in class AbstractXmlSinkModule<SyslogConnection,SyslogMessageLogDTO>
public boolean equals(Object obj)
equals
in class AbstractXmlSinkModule<SyslogConnection,SyslogMessageLogDTO>
Copyright © 2020. All rights reserved.