cgl.narada.benchmark
Class GaugeSubscriber

java.lang.Object
  cgl.narada.benchmark.GaugeSubscriber

All Implemented Interfaces:

NBEventListener, NBRecoveryListener

public class GaugeSubscriber
extends Object
implements NBEventListener, NBRecoveryListener

This class represents the subscribers of the benchmark suite. This benchmark client can also behave as a measuring subscriber responsible for computing latencies, standard deviations, system throughputs etc.

Constructor Summary

GaugeSubscriber(int subscriber)

Method Summary

void	gatherStatsForMessages(int numMessages)
static void	main(String[] args)
void	oldOnEvent(NBEvent nbEvent) The message that would be invoked by the underlying system
void	oldReportStatistics()
void	onEvent(NBEvent nbEvent) The message that would be invoked by the underlying system
void	onRecovery(NBRecoveryNotification recoveryNotification) Upon completion of the attempt to recover, this method is invoked on the listener that was registered with the
void	printToConsole(boolean printInfo)
void	reportStatistics(int messagesInCurrentSet)
void	setAsMeasuringClient(String fileName, int _numOfMessages, int[] messageSizes, int maxRejects)

Methods inherited from class java.lang.Object

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

Constructor Detail

GaugeSubscriber

public GaugeSubscriber(int subscriber)

Method Detail

setAsMeasuringClient

public void setAsMeasuringClient(String fileName,
                                 int _numOfMessages,
                                 int[] messageSizes,
                                 int maxRejects)

printToConsole

public void printToConsole(boolean printInfo)

gatherStatsForMessages

public void gatherStatsForMessages(int numMessages)

onEvent

public void onEvent(NBEvent nbEvent)

The message that would be invoked by the underlying system

Specified by:

onEvent in interface NBEventListener

reportStatistics

public void reportStatistics(int messagesInCurrentSet)

oldOnEvent

public void oldOnEvent(NBEvent nbEvent)

The message that would be invoked by the underlying system

onRecovery

public void onRecovery(NBRecoveryNotification recoveryNotification)

Upon completion of the attempt to recover, this method is invoked on the listener that was registered with the

Specified by:

onRecovery in interface NBRecoveryListener

oldReportStatistics

public void oldReportStatistics()

main

public static void main(String[] args)