Package org.opennms.netmgt.dao.support

Class DefaultFilterWatcher

java.lang.Object

org.opennms.netmgt.dao.support.DefaultFilterWatcher

All Implemented Interfaces:

FilterWatcher, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean

public class DefaultFilterWatcher
extends Object
implements FilterWatcher, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean

Nested Class Summary

Nested classes/interfaces inherited from interface org.opennms.netmgt.dao.api.FilterWatcher

FilterWatcher.FilterResults

Constructor Summary

Constructors

Constructor	Description
DefaultFilterWatcher()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
void	destroy()
long	getRefreshRateLimitMs()
void	inventoryChangeEventHandler(IEvent event)
void	setFilterDao(FilterDao filterDao)
void	setRefreshRateLimitMs(long refreshRateLimitMs)
void	setSessionUtils(SessionUtils sessionUtils)
Closeable	watch(String filterRule, java.util.function.Consumer<FilterWatcher.FilterResults> callback)	Issues callbacks to the given consumer when the results of the filter change.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultFilterWatcher

public DefaultFilterWatcher()

Method Detail

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

destroy

public void destroy()

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

watch

public Closeable watch(String filterRule,
                       java.util.function.Consumer<FilterWatcher.FilterResults> callback)

Description copied from interface: FilterWatcher

Issues callbacks to the given consumer when the results of the filter change. A callback is expected to be issued immediately when the watch session is started. Additional callback will be made if/when the results change.

Specified by:

watch in interface FilterWatcher

Parameters:

filterRule - a valid filter rule if null, or empty the filter will match everything

callback - used for callbacks

Returns:

close when done watching

inventoryChangeEventHandler

public void inventoryChangeEventHandler(IEvent event)

setRefreshRateLimitMs

public void setRefreshRateLimitMs(long refreshRateLimitMs)

getRefreshRateLimitMs

public long getRefreshRateLimitMs()

setFilterDao

public void setFilterDao(FilterDao filterDao)

setSessionUtils

public void setSessionUtils(SessionUtils sessionUtils)