public class BenchmarkPublisher extends BenchmarkWorker
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) |
Modifier and Type | Method and Description |
---|---|
Void |
call() |
PubSubProtocol.Message |
getMsg(int size) |
void |
warmup(int nWarmup) |
public BenchmarkPublisher(int numTopics, int numMessages, int numRegions, int startTopicLabel, int partitionIndex, int numPartitions, Publisher publisher, Subscriber subscriber, int msgSize, int nParallel, int rate)
Copyright © 2011–2016 The Apache Software Foundation. All rights reserved.