Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
MessageDispatcherFactory.createAsyncDispatcher(SinkModule<S,T> module)
Creates a new dispatcher used to send messages asynchronously.
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncDispatcherImpl<W,S extends Message,T extends Message> |
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
AbstractMessageDispatcherFactory.createAsyncDispatcher(SinkModule<S,T> module) |
Modifier and Type | Method and Description |
---|---|
AsyncDispatcher<Event> |
EventDispatcherImpl.getAsyncDispatcher() |
Modifier and Type | Field and Description |
---|---|
protected AsyncDispatcher<SyslogConnection> |
SinkDispatchingSyslogReceiver.m_dispatcher |
Modifier and Type | Method and Description |
---|---|
AsyncDispatcher<TelemetryMessage> |
TelemetryRegistry.getDispatcher(String queueName) |
Modifier and Type | Method and Description |
---|---|
Collection<AsyncDispatcher<TelemetryMessage>> |
TelemetryRegistry.getDispatchers() |
Modifier and Type | Method and Description |
---|---|
void |
TelemetryRegistry.registerDispatcher(String queueName,
AsyncDispatcher<TelemetryMessage> dispatcher) |
Constructor and Description |
---|
ForwardParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher) |
Constructor and Description |
---|
IpfixTcpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
EventForwarder eventForwarder,
Identity identity,
DnsResolver dnsResolver,
com.codahale.metrics.MetricRegistry metricRegistry) |
IpfixUdpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
EventForwarder eventForwarder,
Identity identity,
DnsResolver dnsResolver,
com.codahale.metrics.MetricRegistry metricRegistry) |
Netflow5UdpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
EventForwarder eventForwarder,
Identity identity,
DnsResolver dnsResolver,
com.codahale.metrics.MetricRegistry metricRegistry) |
Netflow9UdpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
EventForwarder eventForwarder,
Identity identity,
DnsResolver dnsResolver,
com.codahale.metrics.MetricRegistry metricRegistry) |
ParserBase(Protocol protocol,
String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
EventForwarder eventForwarder,
Identity identity,
DnsResolver dnsResolver,
com.codahale.metrics.MetricRegistry metricRegistry) |
UdpParserBase(Protocol protocol,
String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
EventForwarder eventForwarder,
Identity identity,
DnsResolver dnsResolver,
com.codahale.metrics.MetricRegistry metricRegistry) |
Modifier and Type | Method and Description |
---|---|
AsyncDispatcher<TelemetryMessage> |
TelemetryRegistryImpl.getDispatcher(String queueName) |
Modifier and Type | Method and Description |
---|---|
Collection<AsyncDispatcher<TelemetryMessage>> |
TelemetryRegistryImpl.getDispatchers() |
Modifier and Type | Method and Description |
---|---|
void |
TelemetryRegistryImpl.registerDispatcher(String queueName,
AsyncDispatcher<TelemetryMessage> dispatcher) |
Constructor and Description |
---|
SFlowUdpParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher,
DnsResolver dnsResolver) |
Copyright © 2020. All rights reserved.