Uses of Interface
org.opennms.core.ipc.sink.api.AsyncDispatcher
-
-
Uses of AsyncDispatcher in org.opennms.core.ipc.sink.api
Methods in org.opennms.core.ipc.sink.api that return AsyncDispatcher Modifier and Type Method Description <S extends Message,T extends Message>
AsyncDispatcher<S>MessageDispatcherFactory. createAsyncDispatcher(SinkModule<S,T> module)
Creates a new dispatcher used to send messages asynchronously. -
Uses of AsyncDispatcher in org.opennms.core.ipc.sink.common
Classes in org.opennms.core.ipc.sink.common that implement AsyncDispatcher Modifier and Type Class Description class
AsyncDispatcherImpl<W,S extends Message,T extends Message>
Methods in org.opennms.core.ipc.sink.common that return AsyncDispatcher Modifier and Type Method Description <S extends Message,T extends Message>
AsyncDispatcher<S>AbstractMessageDispatcherFactory. createAsyncDispatcher(SinkModule<S,T> module)
-
Uses of AsyncDispatcher in org.opennms.features.events.sink.dispatcher
Methods in org.opennms.features.events.sink.dispatcher that return AsyncDispatcher Modifier and Type Method Description AsyncDispatcher<Event>
EventDispatcherImpl. getAsyncDispatcher()
-
Uses of AsyncDispatcher in org.opennms.netmgt.syslogd
Fields in org.opennms.netmgt.syslogd declared as AsyncDispatcher Modifier and Type Field Description protected AsyncDispatcher<SyslogConnection>
SinkDispatchingSyslogReceiver. m_dispatcher
-
Uses of AsyncDispatcher in org.opennms.netmgt.telemetry.api.registry
Methods in org.opennms.netmgt.telemetry.api.registry that return AsyncDispatcher Modifier and Type Method Description AsyncDispatcher<TelemetryMessage>
TelemetryRegistry. getDispatcher(String queueName)
Methods in org.opennms.netmgt.telemetry.api.registry that return types with arguments of type AsyncDispatcher Modifier and Type Method Description Collection<AsyncDispatcher<TelemetryMessage>>
TelemetryRegistry. getDispatchers()
Methods in org.opennms.netmgt.telemetry.api.registry with parameters of type AsyncDispatcher Modifier and Type Method Description void
TelemetryRegistry. registerDispatcher(String queueName, AsyncDispatcher<TelemetryMessage> dispatcher)
-
Uses of AsyncDispatcher in org.opennms.netmgt.telemetry.protocols.bmp.parser
Constructors in org.opennms.netmgt.telemetry.protocols.bmp.parser with parameters of type AsyncDispatcher Constructor Description BmpParser(String name, AsyncDispatcher<TelemetryMessage> dispatcher, DnsResolver dnsResolver, io.github.resilience4j.bulkhead.Bulkhead bulkhead, com.codahale.metrics.MetricRegistry metricRegistry)
-
Uses of AsyncDispatcher in org.opennms.netmgt.telemetry.protocols.common.parser
Constructors in org.opennms.netmgt.telemetry.protocols.common.parser with parameters of type AsyncDispatcher Constructor Description ForwardParser(String name, AsyncDispatcher<TelemetryMessage> dispatcher)
-
Uses of AsyncDispatcher in org.opennms.netmgt.telemetry.protocols.netflow.parser
Constructors in org.opennms.netmgt.telemetry.protocols.netflow.parser with parameters of type AsyncDispatcher Constructor 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)
-
Uses of AsyncDispatcher in org.opennms.netmgt.telemetry.protocols.openconfig.connector
Constructors in org.opennms.netmgt.telemetry.protocols.openconfig.connector with parameters of type AsyncDispatcher Constructor Description OpenConfigConnector(AsyncDispatcher<TelemetryMessage> dispatcher, OpenConfigClientFactory clientFactory)
-
Uses of AsyncDispatcher in org.opennms.netmgt.telemetry.protocols.registry.impl
Methods in org.opennms.netmgt.telemetry.protocols.registry.impl that return AsyncDispatcher Modifier and Type Method Description AsyncDispatcher<TelemetryMessage>
TelemetryRegistryImpl. getDispatcher(String queueName)
Methods in org.opennms.netmgt.telemetry.protocols.registry.impl that return types with arguments of type AsyncDispatcher Modifier and Type Method Description Collection<AsyncDispatcher<TelemetryMessage>>
TelemetryRegistryImpl. getDispatchers()
Methods in org.opennms.netmgt.telemetry.protocols.registry.impl with parameters of type AsyncDispatcher Modifier and Type Method Description void
TelemetryRegistryImpl. registerDispatcher(String queueName, AsyncDispatcher<TelemetryMessage> dispatcher)
-
Uses of AsyncDispatcher in org.opennms.netmgt.telemetry.protocols.sflow.parser
Constructors in org.opennms.netmgt.telemetry.protocols.sflow.parser with parameters of type AsyncDispatcher Constructor Description SFlowUdpParser(String name, AsyncDispatcher<TelemetryMessage> dispatcher, DnsResolver dnsResolver)
-