cgl.narada.benchmark
Class GaugePublisherController

java.lang.Object
  cgl.narada.benchmark.GaugePublisherController

public class GaugePublisherController
extends Object

This class is responsible for cycling through the publish rates, message sizes etc specified in the BenchMarkParams file, create the appropriate number of publishers and control their publish rates and also the payload sizes contained in the messages being published.

Constructor Summary

GaugePublisherController(int numPublishers, int numMessagesPerTestCase, long sleepTimeForCases, int[] messageSizes)

Method Summary

void	initialize(int entityId, Properties props, String commType)
void	initializeThePublishers(String reportDirectory, int templateId, int contentSynopsisType, Object contentSynopsis, int numOfPublishers, Properties pubProperties)
static void	main(String[] args)
void	proceedToGauge()
void	setPublishRateParameters(int[] virtualpubRates, int[] numOfMessagesAtATime, int[] realPubRates)
void	setSonicTest(boolean isSonic)
void	startPublishing(int numOfMessages, int msgSize, int numOfMessagesAtATime, int pubRate, int benchMarkTracker)

Methods inherited from class java.lang.Object

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

Constructor Detail

GaugePublisherController

public GaugePublisherController(int numPublishers,
                                int numMessagesPerTestCase,
                                long sleepTimeForCases,
                                int[] messageSizes)

Method Detail

setSonicTest

public void setSonicTest(boolean isSonic)

setPublishRateParameters

public void setPublishRateParameters(int[] virtualpubRates,
                                     int[] numOfMessagesAtATime,
                                     int[] realPubRates)

initialize

public void initialize(int entityId,
                       Properties props,
                       String commType)
                throws ServiceException

Throws:

ServiceException

initializeThePublishers

public void initializeThePublishers(String reportDirectory,
                                    int templateId,
                                    int contentSynopsisType,
                                    Object contentSynopsis,
                                    int numOfPublishers,
                                    Properties pubProperties)
                             throws ServiceException

Throws:

ServiceException

startPublishing

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

proceedToGauge

public void proceedToGauge()

main

public static void main(String[] args)