org.opennms.features.kafka.producer

Class NodeCache

java.lang.Object

org.opennms.features.kafka.producer.NodeCache

public class NodeCache
extends Object

Constructor Summary

Constructors

Constructor and Description
NodeCache(NodeDao nodeDao, SessionUtils sessionUtils)

Method Summary

Modifier and Type	Method and Description
void	setTimeoutInMs(long timeoutInMs)
void	triggerIfNeeded(long nodeId, java.util.function.Consumer<OnmsNode> consumer)

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeCache

public NodeCache(NodeDao nodeDao,
                 SessionUtils sessionUtils)

Method Detail

triggerIfNeeded

public void triggerIfNeeded(long nodeId,
                            java.util.function.Consumer<OnmsNode> consumer)

setTimeoutInMs

public void setTimeoutInMs(long timeoutInMs)