Package org.opennms.netmgt.telemetry.protocols.bmp.parser

Class BmpParser

java.lang.Object

org.opennms.netmgt.telemetry.protocols.bmp.parser.BmpParser

All Implemented Interfaces:

Parser, TcpParser

public class BmpParser
extends java.lang.Object
implements TcpParser

Nested Class Summary

Nested classes/interfaces inherited from interface org.opennms.netmgt.telemetry.listeners.TcpParser

TcpParser.Handler

Field Summary

Fields

Modifier and Type	Field	Description
static long	HEARTBEAT_INTERVAL
static org.slf4j.Logger	LOG
static com.swrve.ratelimitedlogger.RateLimitedLog	RATE_LIMITED_LOG

Constructor Summary

Constructors

Constructor	Description
BmpParser(java.lang.String name, AsyncDispatcher<TelemetryMessage> dispatcher, DnsResolver dnsResolver, io.github.resilience4j.bulkhead.Bulkhead bulkhead, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method	Description
TcpParser.Handler	accept(java.net.InetSocketAddress remoteAddress, java.net.InetSocketAddress localAddress)
static Transport.IpAddress	address(java.net.InetAddress address)
java.lang.String	getName()
boolean	isDnsLookupsEnabled()
void	setDnsLookupsEnabled(boolean dnsLookupsEnabled)
void	start(java.util.concurrent.ScheduledExecutorService executorService)
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

public static final org.slf4j.Logger LOG

RATE_LIMITED_LOG

public static final com.swrve.ratelimitedlogger.RateLimitedLog RATE_LIMITED_LOG

HEARTBEAT_INTERVAL

public static final long HEARTBEAT_INTERVAL

See Also:

Constant Field Values

Constructor Detail

BmpParser

public BmpParser(java.lang.String name,
                 AsyncDispatcher<TelemetryMessage> dispatcher,
                 DnsResolver dnsResolver,
                 io.github.resilience4j.bulkhead.Bulkhead bulkhead,
                 com.codahale.metrics.MetricRegistry metricRegistry)

Method Detail

getName

public java.lang.String getName()

Specified by:

getName in interface Parser

start

public void start(java.util.concurrent.ScheduledExecutorService executorService)

Specified by:

start in interface Parser

stop

public void stop()

Specified by:

stop in interface Parser

accept

public TcpParser.Handler accept(java.net.InetSocketAddress remoteAddress,
                                java.net.InetSocketAddress localAddress)

Specified by:

accept in interface TcpParser

isDnsLookupsEnabled

public boolean isDnsLookupsEnabled()

setDnsLookupsEnabled

public void setDnsLookupsEnabled(boolean dnsLookupsEnabled)

address

public static Transport.IpAddress address(java.net.InetAddress address)