Package com.nt.udc.testnodechain.queue

Class EventQueueConsumer

java.lang.Object

com.nt.udc.testnodechain.queue.EventQueueConsumer

All Implemented Interfaces:

Callable<Integer>

public class EventQueueConsumer
extends Object
implements Callable<Integer>

Constructor Summary

Constructors

Constructor	Description
EventQueueConsumer(EventQueue eventQueue, String testID, Logger l)

Method Summary

Modifier and Type	Method	Description
Integer	call()
String	getTestID()
void	notifySubscribers(NodeStatisticsDataIfc nodeData)
void	stopConsumer()
void	subscribe(String id, EventQueueConsumeCallbackIfc callbackMethod)
void	unsubscribe(String id)
void	updateGeneralNodeData(NodeStatisticsData nodeData, TNCEvent.EventType eventType, int delta)
void	updateNodeData(NodeStatisticsDataIfc nodeData, TNCEventIfc event, int delta)
void	updateTachyonNodeData(TachyonNodeStatisticsData nodeData, TachyonTNCEvent.TachyonEventType eventType, int delta)

Methods inherited from class java.lang.Object

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

Constructor Details

EventQueueConsumer

public EventQueueConsumer(EventQueue eventQueue,
 String testID,
 Logger l)

Method Details

stopConsumer

public void stopConsumer()

updateNodeData

public void updateNodeData(NodeStatisticsDataIfc nodeData,
 TNCEventIfc event,
 int delta)

updateTachyonNodeData

public void updateTachyonNodeData(TachyonNodeStatisticsData nodeData,
 TachyonTNCEvent.TachyonEventType eventType,
 int delta)

updateGeneralNodeData

public void updateGeneralNodeData(NodeStatisticsData nodeData,
 TNCEvent.EventType eventType,
 int delta)

call

public Integer call()

Specified by:

call in interface Callable<Integer>

subscribe

public void subscribe(String id,
 EventQueueConsumeCallbackIfc callbackMethod)

unsubscribe

public void unsubscribe(String id)

notifySubscribers

public void notifySubscribers(NodeStatisticsDataIfc nodeData)

getTestID

public String getTestID()