org.apache.hedwig.client.benchmark

Class BenchmarkPublisher

java.lang.Object

org.apache.hedwig.client.benchmark.BenchmarkWorker

org.apache.hedwig.client.benchmark.BenchmarkPublisher

public class BenchmarkPublisher
extends BenchmarkWorker

Constructor Summary

Constructors

Constructor and Description
BenchmarkPublisher(int numTopics, int numMessages, int numRegions, int startTopicLabel, int partitionIndex, int numPartitions, Publisher publisher, Subscriber subscriber, int msgSize, int nParallel, int rate)

Method Summary

Modifier and Type	Method and Description
Void	call()
PubSubProtocol.Message	getMsg(int size)
void	warmup(int nWarmup)

Methods inherited from class java.lang.Object

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

Constructor Detail

BenchmarkPublisher

public BenchmarkPublisher(int numTopics,
                          int numMessages,
                          int numRegions,
                          int startTopicLabel,
                          int partitionIndex,
                          int numPartitions,
                          Publisher publisher,
                          Subscriber subscriber,
                          int msgSize,
                          int nParallel,
                          int rate)

Method Detail

warmup

public void warmup(int nWarmup)
            throws Exception

Throws:

Exception

getMsg

public PubSubProtocol.Message getMsg(int size)

call

public Void call()
          throws Exception

Throws:

Exception