cgl.narada.benchmark
Class GaugePublisher

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


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