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 java.lang.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
All Methods Instance Methods Concrete Methods 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)
java.io.Closeable
watch(java.lang.String filterRule, java.util.function.Consumer<FilterWatcher.FilterResults> callback)
Issues callbacks to the given consumer when the results of the filter change.
-
-
-
Method Detail
-
afterPropertiesSet
public void afterPropertiesSet()
- Specified by:
afterPropertiesSet
in interfaceorg.springframework.beans.factory.InitializingBean
-
destroy
public void destroy()
- Specified by:
destroy
in interfaceorg.springframework.beans.factory.DisposableBean
-
watch
public java.io.Closeable watch(java.lang.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 interfaceFilterWatcher
- Parameters:
filterRule
- a valid filter rule if null, or empty the filter will match everythingcallback
- 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)
-
-