cgl.narada.benchmark
Class GaugeSubscriber

java.lang.Object
  extended by 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)


For comments and suggestions please send e-mail to The NaradaBrokering Project