com.ibm.tivoli.nm.collectors.impl.alcatel5620sam.jms

Class Alcatel5620SamJmsQueue

java.lang.Object

com.ibm.tivoli.nm.collectors.impl.alcatel5620sam.jms.Alcatel5620SamJmsQueue

public class Alcatel5620SamJmsQueue
extends java.lang.Object

This class will hold a queue of incoming JMS notification from SAM 5620. There are two threads that will access this class, Alcatel5620SamJmsPush and Alcatel5620SamJmsPull. This class uses FIFO queue method

Author:

Ariff Hakimie

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.locks.Lock	readLock The read lock - to be locked whenever data is being fetched from the queue
protected static java.util.concurrent.locks.ReentrantReadWriteLock	rwLock A lock to manage concurrent access to the queued data, and in doing so maintaining data integrity.
protected static java.util.concurrent.locks.Lock	writeLock The write lock - to be locked whenever data is being written to the queue

Constructor Summary

Constructors

Constructor and Description
Alcatel5620SamJmsQueue()

Method Summary

Modifier and Type	Method and Description
void	addDeviceIdToLoadQueue(java.lang.String deviceId, java.lang.String loadQueueType) Function getting the latest JMS message in the queue
void	addJmsQueue(java.lang.String jmsMessage) Function adding the JMS message to the current queue
static Alcatel5620SamJmsQueue	getEntityLoadQueue() Instance for the loadEntityList
static Alcatel5620SamJmsQueue	getJmsQueue() Instance for the queue so that Alcatel5620SamJmsPush and Alcatel5620SamJmsPull threads will always in sync
java.lang.String	getLatestJmsQueue() Function getting the latest JMS message in the queue
static Alcatel5620SamJmsQueue	getlayer2VpnsLoadQueue() Instance for the loadLayer2Vpns
static Alcatel5620SamJmsQueue	getlayer3VpnsLoadQueue() Instance for the loadLayer3Vpns
java.lang.Object[]	getLoadDeviceListArray(java.lang.String loadType) Function getting the current load list in array
java.lang.String	getLoadDeviceListString(java.lang.String loadType) Function getting the current load list in string
static Alcatel5620SamJmsQueue	getMplsLoadQueue() Instance for the loadMplsInterfaceData

Methods inherited from class java.lang.Object

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

Field Detail

rwLock

protected static java.util.concurrent.locks.ReentrantReadWriteLock rwLock

A lock to manage concurrent access to the queued data, and in doing so maintaining data integrity.

readLock

protected java.util.concurrent.locks.Lock readLock

The read lock - to be locked whenever data is being fetched from the queue

writeLock

protected static java.util.concurrent.locks.Lock writeLock

The write lock - to be locked whenever data is being written to the queue

Constructor Detail

Alcatel5620SamJmsQueue

public Alcatel5620SamJmsQueue()

Method Detail

getJmsQueue

public static Alcatel5620SamJmsQueue getJmsQueue()

Instance for the queue so that Alcatel5620SamJmsPush and Alcatel5620SamJmsPull threads will always in sync

Returns:

the Queue instance

getEntityLoadQueue

public static Alcatel5620SamJmsQueue getEntityLoadQueue()

Instance for the loadEntityList

Returns:

the Queue instance

getMplsLoadQueue

public static Alcatel5620SamJmsQueue getMplsLoadQueue()

Instance for the loadMplsInterfaceData

Returns:

the Queue instance

getlayer2VpnsLoadQueue

public static Alcatel5620SamJmsQueue getlayer2VpnsLoadQueue()

Instance for the loadLayer2Vpns

Returns:

the Queue instance

getlayer3VpnsLoadQueue

public static Alcatel5620SamJmsQueue getlayer3VpnsLoadQueue()

Instance for the loadLayer3Vpns

Returns:

the Queue instance

addJmsQueue

public void addJmsQueue(java.lang.String jmsMessage)

Function adding the JMS message to the current queue

Parameters:

jmsMessage - SAM 5620 JMS notification message

getLatestJmsQueue

public java.lang.String getLatestJmsQueue()

Function getting the latest JMS message in the queue

Returns:

the latest message in queue

addDeviceIdToLoadQueue

public void addDeviceIdToLoadQueue(java.lang.String deviceId,
                                   java.lang.String loadQueueType)

Function getting the latest JMS message in the queue

Parameters:

deviceId - device to be added to the queue

loadQueueType - Load type that is used by the collector loader

getLoadDeviceListArray

public java.lang.Object[] getLoadDeviceListArray(java.lang.String loadType)

Function getting the current load list in array

Parameters:

loadType - collector load type

Returns:

the current list in array

getLoadDeviceListString

public java.lang.String getLoadDeviceListString(java.lang.String loadType)

Function getting the current load list in string

Parameters:

loadType - collector load type

Returns:

the current LoadEntityList list in string