com.tailf.ncs.alarmman.consumer

Class AlarmSourceCentral

Object

com.tailf.ncs.alarmman.consumer.AlarmSourceCentral

All Implemented Interfaces:

AlarmSourceCentralMBean, Runnable

public class AlarmSourceCentral
extends Object
implements Runnable, AlarmSourceCentralMBean

The consuming part of the Alarm API.

This class acts as a proxy where incoming alarms are dispatched or forwarded to all registered AlarmSource attached to it.

One AlarmSourceCentral (and corresponding AlarmSinkCentral) is always present in the NCS JVM and it is started when NCS JVM is started.

It is also possible to start AlarmSourceCentral outside the NCS JVM.

Each client AlarmSource that is attached to a AlarmSourceCentral gets its own queue to check for incoming alarms.

The AlarmSourceCentral maintains or handles the client queues, for each incoming alarm to CDB it creates a new instance of Alarm and puts the new instance into all the client queues that are attached to this AlarmSourceCentral.

Method Summary

Modifier and Type	Method and Description
void	awaitRunning() Deprecated.
static ArrayBlockingQueue<Alarm>	getAlarmQueue() Returns a new alarm queue.
static AlarmSourceCentral	getAlarmSource(int alarmQueueLen, Cdb cdb) Retrieves the alarm source central object.
boolean	isAlive()
static void	returnAlarmQueue(ArrayBlockingQueue<Alarm> queue) Returns the queue.
void	run()
void	start() Start the AlarmSourceCentral which makes it possible for AlarmSource's to attach to this AlarmSourceCentral and receive notifications.
void	stop()

Methods inherited from class Object

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

Method Detail

isAlive

public boolean isAlive()

Specified by:

isAlive in interface AlarmSourceCentralMBean

awaitRunning

@Deprecated
public void awaitRunning()
                              throws InterruptedException

Deprecated.

Throws:

InterruptedException

getAlarmSource

public static AlarmSourceCentral getAlarmSource(int alarmQueueLen,
                                                Cdb cdb)
                                         throws IOException,
                                                NavuException,
                                                ConfException

Retrieves the alarm source central object.

Parameters:

alarmQueueLen - the maximum queue length.

cdb - the CDB socket to subscribe over.

Returns:

the alarm source

Throws:

IOException

NavuException

ConfException

getAlarmQueue

public static ArrayBlockingQueue<Alarm> getAlarmQueue()

Returns a new alarm queue.

Returns:

ArrayBlockingQueue

returnAlarmQueue

public static void returnAlarmQueue(ArrayBlockingQueue<Alarm> queue)

Returns the queue.

Parameters:

queue -

start

public void start()

Start the AlarmSourceCentral which makes it possible for AlarmSource's to attach to this AlarmSourceCentral and receive notifications.

Specified by:

start in interface AlarmSourceCentralMBean

stop

public void stop()

Specified by:

stop in interface AlarmSourceCentralMBean

run

public void run()

Specified by:

run in interface Runnable