org.opennms.netmgt.threshd

Class ThresholdingServiceImpl

java.lang.Object

org.opennms.netmgt.threshd.ThresholdingServiceImpl

All Implemented Interfaces:

EventListener, ThresholdingService

public class ThresholdingServiceImpl
extends Object
implements ThresholdingService, EventListener

Thresholding Service.

Field Summary

Fields

Modifier and Type	Field and Description
static List<String>	UEI_LIST

Constructor Summary

Constructors

Constructor and Description
ThresholdingServiceImpl()

Method Summary

Modifier and Type	Method and Description
void	close(ThresholdingSessionImpl session)
ThresholdingSession	createSession(int nodeId, String hostAddress, String serviceName, RrdRepository repository, ServiceParameters serviceParams) Creates a session to perform Thresholding against.
EventIpcManager	getEventIpcManager()
String	getName() Return the id of the listener
ThresholdingSetPersister	getThresholdingSetPersister()
ThresholdingVisitorImpl	getThresholdingVistor(ThresholdingSession session, Long sequenceNumber)
void	handleNodeCategoryChanged(Event event)
void	initOsgi()
void	nodeGainedService(Event event)
void	onEvent(Event e) Process a sent event.
void	setDistributed(boolean distributed)
void	setEventIpcManager(EventIpcManager eventIpcManager)
void	setEventProxy(EventForwarder eventForwarder)
void	setKvStore(BlobStore keyValueStore)
void	setThresholdingSetPersister(ThresholdingSetPersister thresholdingSetPersister)

Methods inherited from class java.lang.Object

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

Field Detail

UEI_LIST

public static final List<String> UEI_LIST

Constructor Detail

ThresholdingServiceImpl

public ThresholdingServiceImpl()

Method Detail

initOsgi

public void initOsgi()

getName

public String getName()

Description copied from interface: EventListener

Return the id of the listener

Specified by:

getName in interface EventListener

Returns:

a String object.

onEvent

public void onEvent(Event e)

Description copied from interface: EventListener

Process a sent event.

Specified by:

onEvent in interface EventListener

Parameters:

e - a Event object.

nodeGainedService

public void nodeGainedService(Event event)

handleNodeCategoryChanged

public void handleNodeCategoryChanged(Event event)

createSession

public ThresholdingSession createSession(int nodeId,
                                         String hostAddress,
                                         String serviceName,
                                         RrdRepository repository,
                                         ServiceParameters serviceParams)
                                  throws ThresholdInitializationException

Description copied from interface: ThresholdingService

Creates a session to perform Thresholding against. The Session is keyed by the combination of nodeId, hostAddress and serviceName.

Specified by:

createSession in interface ThresholdingService

Parameters:

nodeId - The Node Id.

hostAddress - The Host IP Address.

serviceName - The Service name.

repository - Must not be null. Will be used to resolve Resource Filters and for genertaing Event labels.

serviceParams - Must not be null. Required by some existing CollectionResource objects to evaluate whether to apply thresholds when accepting a CollectionSet. If your CollectionResource does not require this, pass an empty ServiceParameters object.

Returns:

A ThresholdingSession

Throws:

ThresholdInitializationException - if there is an error creating the ThresholdingSession because of invalid Thresholding Configuration.

getThresholdingVistor

public ThresholdingVisitorImpl getThresholdingVistor(ThresholdingSession session,
                                                     Long sequenceNumber)
                                              throws ThresholdInitializationException

Throws:

ThresholdInitializationException

getEventIpcManager

public EventIpcManager getEventIpcManager()

setEventIpcManager

public void setEventIpcManager(EventIpcManager eventIpcManager)

setEventProxy

@Autowired
public void setEventProxy(EventForwarder eventForwarder)

getThresholdingSetPersister

public ThresholdingSetPersister getThresholdingSetPersister()

Specified by:

getThresholdingSetPersister in interface ThresholdingService

setThresholdingSetPersister

public void setThresholdingSetPersister(ThresholdingSetPersister thresholdingSetPersister)

close

public void close(ThresholdingSessionImpl session)

setKvStore

public void setKvStore(BlobStore keyValueStore)

setDistributed

public void setDistributed(boolean distributed)