cgl.narada.benchmark
Class GaugePublisher

java.lang.Object
  cgl.narada.benchmark.GaugePublisher

All Implemented Interfaces:

NBRecoveryListener

public class GaugePublisher
extends Object
implements NBRecoveryListener

This is the class that we use for benching our system. This publisher, publishes messages of different

sizes

types and at

different publish rates

Constructor Summary

GaugePublisher(ClientService clientService, int templateId, int contentSynopsisType, Object contentSynopsis, Properties publisherProperties, String fileName)

Method Summary

static void	main(String[] args)
void	onRecovery(NBRecoveryNotification recoveryNotification) Upon completion of the attempt to recover, this method is invoked on the listener that was registered with the
void	publishMessages(int numOfMessages, int msgSize, int pubRate, int numOfMessagesAtATime, int benchMarkTracker)

Methods inherited from class java.lang.Object

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

Constructor Detail

GaugePublisher

public GaugePublisher(ClientService clientService,
                      int templateId,
                      int contentSynopsisType,
                      Object contentSynopsis,
                      Properties publisherProperties,
                      String fileName)
               throws ServiceException

Throws:

ServiceException

Method Detail

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

publishMessages

public void publishMessages(int numOfMessages,
                            int msgSize,
                            int pubRate,
                            int numOfMessagesAtATime,
                            int benchMarkTracker)

main

public static void main(String[] args)