A B C D E F G H I J L M N O P Q R S T U V W

A

AgentBase - Class in com.rabbitmq.perf

AgentBase(StartListener) - Constructor for class com.rabbitmq.perf.AgentBase

AgentBase.AgentState - Interface in com.rabbitmq.perf

APP_ID_PROPERTY - Static variable in class com.rabbitmq.perf.Producer

args() - Method in class com.rabbitmq.perf.Metrics.ConfigurationContext

B

BaseMetrics - Class in com.rabbitmq.perf

BaseMetrics() - Constructor for class com.rabbitmq.perf.BaseMetrics

BUILD - Static variable in class com.rabbitmq.perf.Version

BUILD_TIMESTAMP - Static variable in class com.rabbitmq.perf.Version

C

close() - Method in class com.rabbitmq.perf.CompositeMetrics

close() - Method in class com.rabbitmq.perf.DatadogMetrics

close() - Method in class com.rabbitmq.perf.JmxMetrics

close() - Method in interface com.rabbitmq.perf.Metrics

close() - Method in class com.rabbitmq.perf.metrics.DefaultPerformanceMetrics

close() - Method in class com.rabbitmq.perf.PrometheusMetrics

close() - Method in class com.rabbitmq.perf.ShutdownService

Close all the registered callbacks, in the reverse order of registration.

CLUSTER_ID_PROPERTY - Static variable in class com.rabbitmq.perf.Producer

cmd() - Method in class com.rabbitmq.perf.Metrics.ConfigurationContext

com.rabbitmq.perf - package com.rabbitmq.perf

com.rabbitmq.perf.metrics - package com.rabbitmq.perf.metrics

CommandLineProxy - Class in com.rabbitmq.perf

A proxy to add behavior around a CommandLine.

CommandLineProxy(Options, CommandLine, Function<String, String>) - Constructor for class com.rabbitmq.perf.CommandLineProxy

CompositeMetrics - Class in com.rabbitmq.perf

CompositeMetrics() - Constructor for class com.rabbitmq.perf.CompositeMetrics

CompositeMetricsFormatter - Class in com.rabbitmq.perf.metrics

Composite formatter that calls a list of formatters for each method.

CompositeMetricsFormatter(MetricsFormatter...) - Constructor for class com.rabbitmq.perf.metrics.CompositeMetricsFormatter

ConfigurationContext(CommandLineProxy, CompositeMeterRegistry, ConnectionFactory, String[], String, Options) - Constructor for class com.rabbitmq.perf.Metrics.ConfigurationContext

configure(Metrics.ConfigurationContext) - Method in class com.rabbitmq.perf.BaseMetrics

configure(Metrics.ConfigurationContext) - Method in class com.rabbitmq.perf.CompositeMetrics

configure(Metrics.ConfigurationContext) - Method in class com.rabbitmq.perf.DatadogMetrics

configure(Metrics.ConfigurationContext) - Method in class com.rabbitmq.perf.JmxMetrics

configure(Metrics.ConfigurationContext) - Method in interface com.rabbitmq.perf.Metrics

configure(Metrics.ConfigurationContext) - Method in class com.rabbitmq.perf.PrometheusMetrics

configureAllQueues(List<Connection>) - Method in class com.rabbitmq.perf.MulticastParams

configureLog() - Static method in class com.rabbitmq.perf.Log

confirmCountInterval - Variable in class com.rabbitmq.perf.Stats

confirmed(int, long[]) - Method in class com.rabbitmq.perf.metrics.DefaultPerformanceMetrics

confirmed(int, long[]) - Method in interface com.rabbitmq.perf.metrics.PerformanceMetrics

confirmed(double) - Method in class com.rabbitmq.perf.Stats

confirmLatency - Variable in class com.rabbitmq.perf.Stats

Consumer - Class in com.rabbitmq.perf

Consumer(ConsumerParameters) - Constructor for class com.rabbitmq.perf.Consumer

ConsumerParameters - Class in com.rabbitmq.perf

ConsumerParameters() - Constructor for class com.rabbitmq.perf.ConsumerParameters

CONTENT_ENCODING_PROPERTY - Static variable in class com.rabbitmq.perf.Producer

CONTENT_TYPE_PROPERTY - Static variable in class com.rabbitmq.perf.Producer

Context(PrintStream, String, boolean, boolean, boolean, boolean, TimeUnit) - Constructor for class com.rabbitmq.perf.metrics.MetricsFormatterFactory.Context

CORRELATION_ID_PROPERTY - Static variable in class com.rabbitmq.perf.Producer

countDown(String) - Method in interface com.rabbitmq.perf.MulticastSet.CompletionHandler

create(int) - Method in class com.rabbitmq.perf.LocalFilesMessageBodySource

create(int) - Method in interface com.rabbitmq.perf.MessageBodySource

create(String, MetricsFormatterFactory.Context) - Static method in class com.rabbitmq.perf.metrics.MetricsFormatterFactory

create(int) - Method in class com.rabbitmq.perf.TimeSequenceMessageBodySource

createConsumer(Connection, PerformanceMetrics, ValueIndicator<Long>, MulticastSet.CompletionHandler, ExecutorService, ScheduledExecutorService) - Method in class com.rabbitmq.perf.MulticastParams

createProducer(Connection, PerformanceMetrics, MulticastSet.CompletionHandler, ValueIndicator<Float>, ValueIndicator<Integer>) - Method in class com.rabbitmq.perf.MulticastParams

createRunnableForScheduling() - Method in class com.rabbitmq.perf.Producer

CsvMetricsFormatter - Class in com.rabbitmq.perf.metrics

Exports metrics to a CSV file.

CsvMetricsFormatter(PrintWriter, String, boolean, boolean, boolean, boolean, TimeUnit) - Constructor for class com.rabbitmq.perf.metrics.CsvMetricsFormatter

cumulativeLatencyInterval - Variable in class com.rabbitmq.perf.Stats

cumulativeLatencyTotal - Variable in class com.rabbitmq.perf.Stats

D

DatadogMetrics - Class in com.rabbitmq.perf

DatadogMetrics() - Constructor for class com.rabbitmq.perf.DatadogMetrics

dealWithWriteOperation(AgentBase.WriteOperation, Recovery.RecoveryProcess) - Method in class com.rabbitmq.perf.AgentBase

DEFAULT_CONSUMER_WORK_SERVICE_THREAD_POOL_SIZE - Static variable in class com.rabbitmq.perf.MulticastSet

DefaultPerformanceMetrics - Class in com.rabbitmq.perf.metrics

Implementation that collects metrics with concurrent utilities.

DefaultPerformanceMetrics(Duration, TimeUnit, MeterRegistry, String, MetricsFormatter) - Constructor for class com.rabbitmq.perf.metrics.DefaultPerformanceMetrics

deleteAutoDeleteQueuesIfNecessary(Connection) - Method in class com.rabbitmq.perf.MulticastParams

DELIVERY_MODE_PROPERTY - Static variable in class com.rabbitmq.perf.Producer

E

elapsedInterval - Variable in class com.rabbitmq.perf.Stats

elapsedTotal - Variable in class com.rabbitmq.perf.Stats

ENVIRONMENT_VARIABLE_PREFIX - Static variable in class com.rabbitmq.perf.PerfTest

exchange(String) - Method in class com.rabbitmq.perf.TopologyRecording

exit(int) - Method in interface com.rabbitmq.perf.PerfTest.SystemExiter

Terminate the currently running Java Virtual Machine.

EXPIRATION_PROPERTY - Static variable in class com.rabbitmq.perf.Producer

F

factory() - Method in class com.rabbitmq.perf.Metrics.ConfigurationContext

fromJSON(Map, ConnectionFactory) - Static method in class com.rabbitmq.perf.ScenarioFactory

G

getBody() - Method in class com.rabbitmq.perf.MessageBodySource.MessageEnvelope

getChannel() - Method in class com.rabbitmq.perf.ConsumerParameters

getChannel() - Method in class com.rabbitmq.perf.ProducerParameters

getCompletionHandler() - Method in class com.rabbitmq.perf.ConsumerParameters

getCompletionHandler() - Method in class com.rabbitmq.perf.ProducerParameters

getConfirm() - Method in class com.rabbitmq.perf.ProducerParameters

getConfirmTimeout() - Method in class com.rabbitmq.perf.ProducerParameters

getConsumerArguments() - Method in class com.rabbitmq.perf.ConsumerParameters

getConsumerChannelCount() - Method in class com.rabbitmq.perf.MulticastParams

getConsumerCount() - Method in class com.rabbitmq.perf.MulticastParams

getConsumerLatencies() - Method in class com.rabbitmq.perf.MulticastParams

getConsumerLatenciesIndicator() - Method in class com.rabbitmq.perf.ConsumerParameters

getConsumerLatencyInMicroseconds() - Method in class com.rabbitmq.perf.MulticastParams

getConsumerMsgCount() - Method in class com.rabbitmq.perf.MulticastParams

getConsumerRateLimit() - Method in class com.rabbitmq.perf.MulticastParams

getConsumerSlowStart() - Method in class com.rabbitmq.perf.MulticastParams

getConsumerStartDelay() - Method in class com.rabbitmq.perf.MulticastParams

getConsumersThreadPools() - Method in class com.rabbitmq.perf.MulticastParams

getConsumerThreadCount() - Method in class com.rabbitmq.perf.MulticastParams

getContentType() - Method in class com.rabbitmq.perf.MessageBodySource.MessageEnvelope

getCurrentTime() - Method in class com.rabbitmq.perf.TimestampProvider

getDifference(long, long) - Method in class com.rabbitmq.perf.TimestampProvider

getExchangeName() - Method in class com.rabbitmq.perf.ProducerParameters

getExecutorService() - Method in class com.rabbitmq.perf.ConsumerParameters

getExitWhen() - Method in class com.rabbitmq.perf.ConsumerParameters

getExitWhen() - Method in class com.rabbitmq.perf.MulticastParams

getFlags() - Method in class com.rabbitmq.perf.ProducerParameters

getHeartbeatSenderThreads() - Method in class com.rabbitmq.perf.MulticastParams

getId() - Method in class com.rabbitmq.perf.ConsumerParameters

getId() - Method in class com.rabbitmq.perf.ProducerParameters

getLastStatsTime() - Method in interface com.rabbitmq.perf.AgentBase.AgentState

getMessageBodySource() - Method in class com.rabbitmq.perf.ProducerParameters

getMessageProperties() - Method in class com.rabbitmq.perf.ProducerParameters

getMessageSizes() - Method in class com.rabbitmq.perf.MulticastParams

getMinMsgSize() - Method in class com.rabbitmq.perf.MulticastParams

getMsgCount() - Method in interface com.rabbitmq.perf.AgentBase.AgentState

getMsgLimit() - Method in class com.rabbitmq.perf.ConsumerParameters

getMsgLimit() - Method in class com.rabbitmq.perf.ProducerParameters

getMultiAckEvery() - Method in class com.rabbitmq.perf.ConsumerParameters

getName() - Method in class com.rabbitmq.perf.RateVsLatencyScenario

getName() - Method in interface com.rabbitmq.perf.Scenario

getName() - Method in class com.rabbitmq.perf.SimpleScenario

getName() - Method in interface com.rabbitmq.perf.VariableValue

getName() - Method in class com.rabbitmq.perf.VaryingScenario

getNioNbThreadsAndExecutorSize(int, int) - Static method in class com.rabbitmq.perf.PerfTest

getOptions() - Static method in class com.rabbitmq.perf.PerfTest

getOptionValue(char, String) - Method in class com.rabbitmq.perf.CommandLineProxy

getOptionValue(String, String) - Method in class com.rabbitmq.perf.CommandLineProxy

getOptionValue(char) - Method in class com.rabbitmq.perf.CommandLineProxy

getOptionValues(char) - Method in class com.rabbitmq.perf.CommandLineProxy

getOptionValues(String) - Method in class com.rabbitmq.perf.CommandLineProxy

getPerformanceMetrics() - Method in class com.rabbitmq.perf.ConsumerParameters

getPerformanceMetrics() - Method in class com.rabbitmq.perf.ProducerParameters

getPollingInterval() - Method in class com.rabbitmq.perf.ConsumerParameters

getProducerChannelCount() - Method in class com.rabbitmq.perf.MulticastParams

getProducerCount() - Method in class com.rabbitmq.perf.MulticastParams

getProducerMsgCount() - Method in class com.rabbitmq.perf.MulticastParams

getProducerRandomStartDelayInSeconds() - Method in class com.rabbitmq.perf.MulticastParams

getProducerRateLimit() - Method in class com.rabbitmq.perf.MulticastParams

getProducerSchedulerThreadCount() - Method in class com.rabbitmq.perf.MulticastParams

getProducerThreadCount() - Method in class com.rabbitmq.perf.MulticastParams

getPublishingInterval() - Method in class com.rabbitmq.perf.MulticastParams

getPublishingRates() - Method in class com.rabbitmq.perf.MulticastParams

getQueueNames() - Method in class com.rabbitmq.perf.ConsumerParameters

getRandomStartDelayInSeconds() - Method in class com.rabbitmq.perf.ProducerParameters

getRateIndicator() - Method in class com.rabbitmq.perf.ProducerParameters

getRateLimit() - Method in class com.rabbitmq.perf.ConsumerParameters

getRecoveryProcess() - Method in class com.rabbitmq.perf.ConsumerParameters

getRecoveryProcess() - Method in class com.rabbitmq.perf.ProducerParameters

getRoutingKeyCacheSize() - Method in class com.rabbitmq.perf.ProducerParameters

getServersStartUpTimeout() - Method in class com.rabbitmq.perf.MulticastParams

getServersUpLimit() - Method in class com.rabbitmq.perf.MulticastParams

getShutdownTimeout() - Method in class com.rabbitmq.perf.MulticastParams

getStartListener() - Method in class com.rabbitmq.perf.ConsumerParameters

getStartListener() - Method in class com.rabbitmq.perf.ProducerParameters

getStats() - Method in class com.rabbitmq.perf.RateVsLatencyScenario

getStats() - Method in interface com.rabbitmq.perf.Scenario

getStats() - Method in class com.rabbitmq.perf.SimpleScenario

getStats() - Method in class com.rabbitmq.perf.VaryingScenario

getTime() - Method in class com.rabbitmq.perf.MessageBodySource.MessageEnvelope

getTimeLimit() - Method in class com.rabbitmq.perf.MulticastParams

getTimestampProvider() - Method in class com.rabbitmq.perf.ConsumerParameters

getTopologyRecoveryScheduledExecutorService() - Method in class com.rabbitmq.perf.ConsumerParameters

getTsp() - Method in class com.rabbitmq.perf.ProducerParameters

getTxSize() - Method in class com.rabbitmq.perf.ConsumerParameters

getTxSize() - Method in class com.rabbitmq.perf.ProducerParameters

getValue() - Method in interface com.rabbitmq.perf.VariableValue

getValues() - Method in class com.rabbitmq.perf.MulticastVariable

getValues() - Method in interface com.rabbitmq.perf.Variable

globalConfirmLatency - Variable in class com.rabbitmq.perf.Stats

globalLatency - Variable in class com.rabbitmq.perf.Stats

H

handleAck(long, boolean) - Method in class com.rabbitmq.perf.Producer

handleConfirm(int, long[]) - Method in class com.rabbitmq.perf.Stats

handleNack(long, boolean) - Method in class com.rabbitmq.perf.Producer

handleNack(int) - Method in class com.rabbitmq.perf.Stats

handlePublish(AgentBase.AgentState) - Method in class com.rabbitmq.perf.Producer

handleRecv(long) - Method in class com.rabbitmq.perf.Stats

handleReturn(int, String, String, String, AMQP.BasicProperties, byte[]) - Method in class com.rabbitmq.perf.Producer

handleReturn() - Method in class com.rabbitmq.perf.Stats

handleSend() - Method in class com.rabbitmq.perf.Stats

handleShutdownSignalExceptionOnWrite(Recovery.RecoveryProcess, ShutdownSignalException) - Method in class com.rabbitmq.perf.AgentBase

hasLimit() - Method in class com.rabbitmq.perf.MulticastParams

hasOption(char) - Method in class com.rabbitmq.perf.CommandLineProxy

hasOption(String) - Method in class com.rabbitmq.perf.CommandLineProxy

header() - Method in class com.rabbitmq.perf.metrics.CompositeMetricsFormatter

header() - Method in class com.rabbitmq.perf.metrics.CsvMetricsFormatter

header() - Method in interface com.rabbitmq.perf.metrics.MetricsFormatter

I

incrementMessageCount() - Method in interface com.rabbitmq.perf.AgentBase.AgentState

init() - Method in class com.rabbitmq.perf.MulticastParams

interval() - Method in class com.rabbitmq.perf.metrics.DefaultPerformanceMetrics

interval() - Method in interface com.rabbitmq.perf.metrics.PerformanceMetrics

isAutoAck() - Method in class com.rabbitmq.perf.ConsumerParameters

isConnectionRecoveryTriggered(ShutdownSignalException) - Method in class com.rabbitmq.perf.AgentBase

isEnabled(CommandLineProxy) - Method in class com.rabbitmq.perf.CompositeMetrics

isEnabled(CommandLineProxy) - Method in interface com.rabbitmq.perf.Metrics

isExclusive() - Method in class com.rabbitmq.perf.MulticastParams

isNack() - Method in class com.rabbitmq.perf.ConsumerParameters

isPolling() - Method in class com.rabbitmq.perf.ConsumerParameters

isPolling() - Method in class com.rabbitmq.perf.MulticastParams

isRandomRoutingKey() - Method in class com.rabbitmq.perf.ProducerParameters

isRequeue() - Method in class com.rabbitmq.perf.ConsumerParameters

isTimestampInHeader() - Method in class com.rabbitmq.perf.TimestampProvider

J

JmxMetrics - Class in com.rabbitmq.perf

JmxMetrics() - Constructor for class com.rabbitmq.perf.JmxMetrics

L

lastStatsTime - Variable in class com.rabbitmq.perf.Stats

latency - Variable in class com.rabbitmq.perf.Stats

latencyCountInterval - Variable in class com.rabbitmq.perf.Stats

latencyCountTotal - Variable in class com.rabbitmq.perf.Stats

LocalFilesMessageBodySource - Class in com.rabbitmq.perf

LocalFilesMessageBodySource(List<String>, String) - Constructor for class com.rabbitmq.perf.LocalFilesMessageBodySource

LocalFilesMessageBodySource(List<String>) - Constructor for class com.rabbitmq.perf.LocalFilesMessageBodySource

Log - Class in com.rabbitmq.perf

Configure logback.

Log() - Constructor for class com.rabbitmq.perf.Log

log(String, Throwable) - Method in class com.rabbitmq.perf.RelaxedExceptionHandler

LONG_OPTION_TO_ENVIRONMENT_VARIABLE - Static variable in class com.rabbitmq.perf.PerfTest

M

main(String[], PerfTest.PerfTestOptions) - Static method in class com.rabbitmq.perf.PerfTest

main(String[]) - Static method in class com.rabbitmq.perf.PerfTest

main(String[]) - Static method in class com.rabbitmq.perf.PerfTestMulti

maxLatency - Variable in class com.rabbitmq.perf.Stats

maybeHandlePublish(AgentBase.AgentState) - Method in class com.rabbitmq.perf.Producer

MESSAGE_ID_PROPERTY - Static variable in class com.rabbitmq.perf.Producer

MessageBodySource - Interface in com.rabbitmq.perf

Sources produce message bodies and content type used by publishers.

MessageBodySource.MessageEnvelope - Class in com.rabbitmq.perf

MessageEnvelope(byte[], String, long) - Constructor for class com.rabbitmq.perf.MessageBodySource.MessageEnvelope

meterRegistry() - Method in class com.rabbitmq.perf.Metrics.ConfigurationContext

Metrics - Interface in com.rabbitmq.perf

Metrics.ConfigurationContext - Class in com.rabbitmq.perf

MetricsFormatter - Interface in com.rabbitmq.perf.metrics

Contract to format and output metrics.

MetricsFormatterFactory - Class in com.rabbitmq.perf.metrics

Factory to create MetricsFormatter.

MetricsFormatterFactory() - Constructor for class com.rabbitmq.perf.metrics.MetricsFormatterFactory

MetricsFormatterFactory.Context - Class in com.rabbitmq.perf.metrics

metricsOptions() - Method in class com.rabbitmq.perf.Metrics.ConfigurationContext

metricsPrefix() - Method in class com.rabbitmq.perf.Metrics.ConfigurationContext

minLatency - Variable in class com.rabbitmq.perf.Stats

MulticastParams - Class in com.rabbitmq.perf

MulticastParams() - Constructor for class com.rabbitmq.perf.MulticastParams

MulticastSet - Class in com.rabbitmq.perf

MulticastSet(PerformanceMetrics, ConnectionFactory, MulticastParams, List<String>, MulticastSet.CompletionHandler) - Constructor for class com.rabbitmq.perf.MulticastSet

MulticastSet(PerformanceMetrics, ConnectionFactory, MulticastParams, String, List<String>, MulticastSet.CompletionHandler) - Constructor for class com.rabbitmq.perf.MulticastSet

MulticastSet(PerformanceMetrics, ConnectionFactory, MulticastParams, String, List<String>, MulticastSet.CompletionHandler, ShutdownService, ExpectedMetrics) - Constructor for class com.rabbitmq.perf.MulticastSet

MulticastSet.CompletionHandler - Interface in com.rabbitmq.perf

MulticastVariable - Class in com.rabbitmq.perf

MulticastVariable(String, Object...) - Constructor for class com.rabbitmq.perf.MulticastVariable

N

nackCountInterval - Variable in class com.rabbitmq.perf.Stats

nacked(int) - Method in class com.rabbitmq.perf.metrics.DefaultPerformanceMetrics

nacked(int) - Method in interface com.rabbitmq.perf.metrics.PerformanceMetrics

nacked(double) - Method in class com.rabbitmq.perf.Stats

NamedThreadFactory - Class in com.rabbitmq.perf

A ThreadFactory that names threads with a prefix and a sequence number.

NamedThreadFactory(String) - Constructor for class com.rabbitmq.perf.NamedThreadFactory

NamedThreadFactory(ThreadFactory, String) - Constructor for class com.rabbitmq.perf.NamedThreadFactory

NANO_TO_SECOND - Static variable in class com.rabbitmq.perf.Stats

nbThreadsForConsumer(MulticastParams) - Static method in class com.rabbitmq.perf.MulticastSet

nbThreadsForProducerScheduledExecutorService(MulticastParams) - Static method in class com.rabbitmq.perf.MulticastSet

newThread(Runnable) - Method in class com.rabbitmq.perf.NamedThreadFactory

next(List<VariableValue>) - Method in class com.rabbitmq.perf.VaryingScenarioStats

NO_OP - Static variable in interface com.rabbitmq.perf.metrics.PerformanceMetrics

NO_OP_RECOVERY_PROCESS - Static variable in class com.rabbitmq.perf.Recovery

O

options() - Method in class com.rabbitmq.perf.BaseMetrics

options() - Method in class com.rabbitmq.perf.CompositeMetrics

options() - Method in class com.rabbitmq.perf.DatadogMetrics

options() - Method in class com.rabbitmq.perf.JmxMetrics

options() - Method in interface com.rabbitmq.perf.Metrics

options() - Method in class com.rabbitmq.perf.PrometheusMetrics

OptionsUtils - Class in com.rabbitmq.perf

OptionsUtils() - Constructor for class com.rabbitmq.perf.OptionsUtils

P

PerformanceMetrics - Interface in com.rabbitmq.perf.metrics

Contract to collect metrics during a run.

PerfTest - Class in com.rabbitmq.perf

PerfTest() - Constructor for class com.rabbitmq.perf.PerfTest

PerfTest.PerfTestOptions - Class in com.rabbitmq.perf

Abstraction to ease testing or PerfTest usage as a library.

PerfTest.SystemExiter - Interface in com.rabbitmq.perf

Interface for exiting the JVM.

PerfTestMulti - Class in com.rabbitmq.perf

PerfTestMulti() - Constructor for class com.rabbitmq.perf.PerfTestMulti

PerfTestOptions() - Constructor for class com.rabbitmq.perf.PerfTest.PerfTestOptions

PerfUtil - Class in com.rabbitmq.perf

PerfUtil() - Constructor for class com.rabbitmq.perf.PerfUtil

PRIORITY_PROPERTY - Static variable in class com.rabbitmq.perf.Producer

Producer - Class in com.rabbitmq.perf

Producer(ProducerParameters) - Constructor for class com.rabbitmq.perf.Producer

ProducerParameters - Class in com.rabbitmq.perf

ProducerParameters() - Constructor for class com.rabbitmq.perf.ProducerParameters

PrometheusMetrics - Class in com.rabbitmq.perf

PrometheusMetrics() - Constructor for class com.rabbitmq.perf.PrometheusMetrics

published() - Method in class com.rabbitmq.perf.metrics.DefaultPerformanceMetrics

published() - Method in interface com.rabbitmq.perf.metrics.PerformanceMetrics

published(double) - Method in class com.rabbitmq.perf.Stats

Q

queue(String) - Method in class com.rabbitmq.perf.TopologyRecording

R

RateVsLatencyScenario - Class in com.rabbitmq.perf

RateVsLatencyScenario(String, ConnectionFactory, MulticastParams) - Constructor for class com.rabbitmq.perf.RateVsLatencyScenario

received(long) - Method in class com.rabbitmq.perf.metrics.DefaultPerformanceMetrics

received(long) - Method in interface com.rabbitmq.perf.metrics.PerformanceMetrics

received(double) - Method in class com.rabbitmq.perf.Stats

recordBinding(String, String, String) - Method in class com.rabbitmq.perf.TopologyRecording

recordExchange(String, String) - Method in class com.rabbitmq.perf.TopologyRecording

recordQueue(String, boolean, boolean, boolean, Map<String, Object>, boolean) - Method in class com.rabbitmq.perf.TopologyRecording

recover(TopologyRecording) - Method in class com.rabbitmq.perf.AgentBase

recover(TopologyRecording) - Method in class com.rabbitmq.perf.Consumer

recover(TopologyRecording) - Method in class com.rabbitmq.perf.Producer

recover(Connection) - Method in class com.rabbitmq.perf.TopologyRecording

Recovery - Class in com.rabbitmq.perf

Recovery() - Constructor for class com.rabbitmq.perf.Recovery

recvCountInterval - Variable in class com.rabbitmq.perf.Stats

recvCountTotal - Variable in class com.rabbitmq.perf.Stats

RelaxedExceptionHandler - Class in com.rabbitmq.perf

Relaxed version of the DefaultExceptionHandler that logs network exceptions as info instead of warn.

RelaxedExceptionHandler() - Constructor for class com.rabbitmq.perf.RelaxedExceptionHandler

REPLY_TO_PROPERTY - Static variable in class com.rabbitmq.perf.Producer

report(Duration, double, double, double, double, double, long[], long[]) - Method in class com.rabbitmq.perf.metrics.CompositeMetricsFormatter

report(Duration, double, double, double, double, double, long[], long[]) - Method in class com.rabbitmq.perf.metrics.CsvMetricsFormatter

report(Duration, double, double, double, double, double, long[], long[]) - Method in interface com.rabbitmq.perf.metrics.MetricsFormatter

report(long) - Method in class com.rabbitmq.perf.Stats

resetGlobals() - Method in class com.rabbitmq.perf.metrics.DefaultPerformanceMetrics

resetGlobals() - Method in interface com.rabbitmq.perf.metrics.PerformanceMetrics

resetTopologyHandler() - Method in class com.rabbitmq.perf.MulticastParams

results() - Method in interface com.rabbitmq.perf.ScenarioStats

results() - Method in class com.rabbitmq.perf.VaryingScenarioStats

returnCountInterval - Variable in class com.rabbitmq.perf.Stats

returned() - Method in class com.rabbitmq.perf.metrics.DefaultPerformanceMetrics

returned() - Method in interface com.rabbitmq.perf.metrics.PerformanceMetrics

returned(double) - Method in class com.rabbitmq.perf.Stats

run() - Method in class com.rabbitmq.perf.Consumer

run() - Method in class com.rabbitmq.perf.MulticastSet

run(boolean) - Method in class com.rabbitmq.perf.MulticastSet

run() - Method in class com.rabbitmq.perf.Producer

run() - Method in class com.rabbitmq.perf.RateVsLatencyScenario

run() - Method in interface com.rabbitmq.perf.Scenario

run() - Method in class com.rabbitmq.perf.SimpleScenario

run() - Method in class com.rabbitmq.perf.VaryingScenario

S

Scenario - Interface in com.rabbitmq.perf

ScenarioFactory - Class in com.rabbitmq.perf

ScenarioFactory() - Constructor for class com.rabbitmq.perf.ScenarioFactory

ScenarioStats - Interface in com.rabbitmq.perf

sendCountInterval - Variable in class com.rabbitmq.perf.Stats

sendCountTotal - Variable in class com.rabbitmq.perf.Stats

setArgumentLookup(Function<String, String>) - Method in class com.rabbitmq.perf.PerfTest.PerfTestOptions

setAutoAck(boolean) - Method in class com.rabbitmq.perf.ConsumerParameters

setAutoAck(boolean) - Method in class com.rabbitmq.perf.MulticastParams

setAutoDelete(boolean) - Method in class com.rabbitmq.perf.MulticastParams

setBodyContentType(String) - Method in class com.rabbitmq.perf.MulticastParams

setBodyCount(int) - Method in class com.rabbitmq.perf.MulticastParams

setBodyFieldCount(int) - Method in class com.rabbitmq.perf.MulticastParams

setBodyFiles(List<String>) - Method in class com.rabbitmq.perf.MulticastParams

setChannel(Channel) - Method in class com.rabbitmq.perf.ConsumerParameters

setChannel(Channel) - Method in class com.rabbitmq.perf.ProducerParameters

setChannelPrefetch(int) - Method in class com.rabbitmq.perf.MulticastParams

setCompletionHandler(MulticastSet.CompletionHandler) - Method in class com.rabbitmq.perf.ConsumerParameters

setCompletionHandler(MulticastSet.CompletionHandler) - Method in class com.rabbitmq.perf.ProducerParameters

setConfirm(long) - Method in class com.rabbitmq.perf.MulticastParams

setConfirm(long) - Method in class com.rabbitmq.perf.ProducerParameters

setConfirmTimeout(int) - Method in class com.rabbitmq.perf.MulticastParams

setConfirmTimeout(int) - Method in class com.rabbitmq.perf.ProducerParameters

setConsumerArguments(Map<String, Object>) - Method in class com.rabbitmq.perf.ConsumerParameters

setConsumerArguments(Map<String, Object>) - Method in class com.rabbitmq.perf.MulticastParams

setConsumerChannelCount(int) - Method in class com.rabbitmq.perf.MulticastParams

setConsumerCount(int) - Method in class com.rabbitmq.perf.MulticastParams

setConsumerLatencies(List<String>) - Method in class com.rabbitmq.perf.MulticastParams

setConsumerLatencyIndicator(ValueIndicator<Long>) - Method in class com.rabbitmq.perf.ConsumerParameters

setConsumerLatencyInMicroseconds(long) - Method in class com.rabbitmq.perf.MulticastParams

setConsumerMsgCount(int) - Method in class com.rabbitmq.perf.MulticastParams

setConsumerPrefetch(int) - Method in class com.rabbitmq.perf.MulticastParams

setConsumerRateLimit(float) - Method in class com.rabbitmq.perf.MulticastParams

setConsumerSlowStart(boolean) - Method in class com.rabbitmq.perf.MulticastParams

setConsumersThreadPools(int) - Method in class com.rabbitmq.perf.MulticastParams

setConsumerTxSize(int) - Method in class com.rabbitmq.perf.MulticastParams

setExceptionHandler(ExceptionHandler) - Method in class com.rabbitmq.perf.PerfTest.PerfTestOptions

setExchangeName(String) - Method in class com.rabbitmq.perf.MulticastParams

setExchangeName(String) - Method in class com.rabbitmq.perf.ProducerParameters

setExchangeType(String) - Method in class com.rabbitmq.perf.MulticastParams

setExclusive(boolean) - Method in class com.rabbitmq.perf.MulticastParams

setExecutorService(ExecutorService) - Method in class com.rabbitmq.perf.ConsumerParameters

setExitWhen(PerfTest.EXIT_WHEN) - Method in class com.rabbitmq.perf.ConsumerParameters

setExitWhen(PerfTest.EXIT_WHEN) - Method in class com.rabbitmq.perf.MulticastParams

setFlags(List<String>) - Method in class com.rabbitmq.perf.MulticastParams

setFlags(List<?>) - Method in class com.rabbitmq.perf.ProducerParameters

setHeartbeatSenderThreads(int) - Method in class com.rabbitmq.perf.MulticastParams

setId(String) - Method in class com.rabbitmq.perf.ConsumerParameters

setId(String) - Method in class com.rabbitmq.perf.ProducerParameters

setJsonBody(boolean) - Method in class com.rabbitmq.perf.MulticastParams

setMessageBodySource(MessageBodySource) - Method in class com.rabbitmq.perf.ProducerParameters

setMessageProperties(Map<String, Object>) - Method in class com.rabbitmq.perf.MulticastParams

setMessageProperties(Map<String, Object>) - Method in class com.rabbitmq.perf.ProducerParameters

setMessageSizes(List<String>) - Method in class com.rabbitmq.perf.MulticastParams

setMinMsgSize(int) - Method in class com.rabbitmq.perf.MulticastParams

setMsgCount(int) - Method in class com.rabbitmq.perf.MulticastParams

setMsgLimit(int) - Method in class com.rabbitmq.perf.ConsumerParameters

setMsgLimit(int) - Method in class com.rabbitmq.perf.ProducerParameters

setMultiAckEvery(int) - Method in class com.rabbitmq.perf.ConsumerParameters

setMultiAckEvery(int) - Method in class com.rabbitmq.perf.MulticastParams

setNack(boolean) - Method in class com.rabbitmq.perf.ConsumerParameters

setNack(boolean) - Method in class com.rabbitmq.perf.MulticastParams

setPerformanceMetrics(PerformanceMetrics) - Method in class com.rabbitmq.perf.ConsumerParameters

setPerformanceMetrics(PerformanceMetrics) - Method in class com.rabbitmq.perf.ProducerParameters

setPolling(boolean) - Method in class com.rabbitmq.perf.ConsumerParameters

setPolling(boolean) - Method in class com.rabbitmq.perf.MulticastParams

setPollingInterval(int) - Method in class com.rabbitmq.perf.ConsumerParameters

setPollingInterval(int) - Method in class com.rabbitmq.perf.MulticastParams

setPredeclared(boolean) - Method in class com.rabbitmq.perf.MulticastParams

setProducerChannelCount(int) - Method in class com.rabbitmq.perf.MulticastParams

setProducerCount(int) - Method in class com.rabbitmq.perf.MulticastParams

setProducerMsgCount(int) - Method in class com.rabbitmq.perf.MulticastParams

setProducerRandomStartDelayInSeconds(int) - Method in class com.rabbitmq.perf.MulticastParams

setProducerRateLimit(float) - Method in class com.rabbitmq.perf.MulticastParams

setProducerSchedulerThreadCount(int) - Method in class com.rabbitmq.perf.MulticastParams

setProducerTxSize(int) - Method in class com.rabbitmq.perf.MulticastParams

setPublishingInterval(Duration) - Method in class com.rabbitmq.perf.MulticastParams

setPublishingRates(List<String>) - Method in class com.rabbitmq.perf.MulticastParams

setQueueArguments(Map<String, Object>) - Method in class com.rabbitmq.perf.MulticastParams

setQueueNames(List<String>) - Method in class com.rabbitmq.perf.ConsumerParameters

setQueueNames(List<String>) - Method in class com.rabbitmq.perf.MulticastParams

setQueuePattern(String) - Method in class com.rabbitmq.perf.MulticastParams

setQueueSequenceFrom(int) - Method in class com.rabbitmq.perf.MulticastParams

setQueueSequenceTo(int) - Method in class com.rabbitmq.perf.MulticastParams

setQueuesInSequence(boolean) - Method in class com.rabbitmq.perf.MulticastParams

setRandomRoutingKey(boolean) - Method in class com.rabbitmq.perf.MulticastParams

setRandomRoutingKey(boolean) - Method in class com.rabbitmq.perf.ProducerParameters

setRandomStartDelayInSeconds(int) - Method in class com.rabbitmq.perf.ProducerParameters

setRateIndicator(ValueIndicator<Float>) - Method in class com.rabbitmq.perf.ProducerParameters

setRateLimit(float) - Method in class com.rabbitmq.perf.ConsumerParameters

setRecoveryProcess(Recovery.RecoveryProcess) - Method in class com.rabbitmq.perf.ConsumerParameters

setRecoveryProcess(Recovery.RecoveryProcess) - Method in class com.rabbitmq.perf.ProducerParameters

setRequeue(boolean) - Method in class com.rabbitmq.perf.ConsumerParameters

setRequeue(boolean) - Method in class com.rabbitmq.perf.MulticastParams

setRoutingKey(String) - Method in class com.rabbitmq.perf.MulticastParams

setRoutingKeyCacheSize(int) - Method in class com.rabbitmq.perf.MulticastParams

setRoutingKeyCacheSize(int) - Method in class com.rabbitmq.perf.ProducerParameters

setServersStartUpTimeout(int) - Method in class com.rabbitmq.perf.MulticastParams

setServersUpLimit(int) - Method in class com.rabbitmq.perf.MulticastParams

setShutdownService(ShutdownService) - Method in class com.rabbitmq.perf.PerfTest.PerfTestOptions

setShutdownTimeout(int) - Method in class com.rabbitmq.perf.MulticastParams

setSkipBindingQueues(boolean) - Method in class com.rabbitmq.perf.MulticastParams

setSkipSslContextConfiguration(boolean) - Method in class com.rabbitmq.perf.PerfTest.PerfTestOptions

setStartListener(StartListener) - Method in class com.rabbitmq.perf.ConsumerParameters

setStartListener(StartListener) - Method in class com.rabbitmq.perf.MulticastParams

setStartListener(StartListener) - Method in class com.rabbitmq.perf.ProducerParameters

setSystemExiter(PerfTest.SystemExiter) - Method in class com.rabbitmq.perf.PerfTest.PerfTestOptions

setThreadingHandler(MulticastSet.ThreadingHandler) - Method in class com.rabbitmq.perf.MulticastSet

setTimeLimit(int) - Method in class com.rabbitmq.perf.MulticastParams

setTimestampProvider(TimestampProvider) - Method in class com.rabbitmq.perf.ConsumerParameters

setTopologyRecording(TopologyRecording) - Method in class com.rabbitmq.perf.AgentBase

setTsp(TimestampProvider) - Method in class com.rabbitmq.perf.ProducerParameters

setTxSize(int) - Method in class com.rabbitmq.perf.ConsumerParameters

setTxSize(int) - Method in class com.rabbitmq.perf.ProducerParameters

setup(MulticastParams) - Method in interface com.rabbitmq.perf.VariableValue

setUseMillis(boolean) - Method in class com.rabbitmq.perf.MulticastParams

setValue(Object, Object, Object) - Static method in class com.rabbitmq.perf.PerfUtil

shouldStop(Recovery.RecoveryProcess, ShutdownSignalException) - Method in class com.rabbitmq.perf.AgentBase

ShutdownService - Class in com.rabbitmq.perf

Helper to register callbacks and call them in reverse order.

ShutdownService() - Constructor for class com.rabbitmq.perf.ShutdownService

SimpleScenario - Class in com.rabbitmq.perf

SimpleScenario(String, ConnectionFactory, MulticastParams...) - Constructor for class com.rabbitmq.perf.SimpleScenario

SimpleScenario(String, ConnectionFactory, long, MulticastParams...) - Constructor for class com.rabbitmq.perf.SimpleScenario

start() - Method in class com.rabbitmq.perf.metrics.DefaultPerformanceMetrics

start() - Method in interface com.rabbitmq.perf.metrics.PerformanceMetrics

started() - Method in class com.rabbitmq.perf.AgentBase

startTime - Variable in class com.rabbitmq.perf.Stats

startTimeForGlobals - Variable in class com.rabbitmq.perf.Stats

Stats - Class in com.rabbitmq.perf

Stats(Duration) - Constructor for class com.rabbitmq.perf.Stats

Stats(Duration, boolean, MeterRegistry, String) - Constructor for class com.rabbitmq.perf.Stats

Stats(Duration, boolean, MeterRegistry, String, PerformanceMetrics) - Constructor for class com.rabbitmq.perf.Stats

subRecording(Collection<String>) - Method in class com.rabbitmq.perf.TopologyRecording

Create a subset of the topology of this recording for the passed-in queues.

summary(Duration, double, double, long[], long[]) - Method in class com.rabbitmq.perf.metrics.CompositeMetricsFormatter

summary(Duration, double, double, long[], long[]) - Method in class com.rabbitmq.perf.metrics.CsvMetricsFormatter

summary(Duration, double, double, long[], long[]) - Method in interface com.rabbitmq.perf.metrics.MetricsFormatter

T

teardown(MulticastParams) - Method in interface com.rabbitmq.perf.VariableValue

TimeSequenceMessageBodySource - Class in com.rabbitmq.perf

TimeSequenceMessageBodySource(TimestampProvider, int) - Constructor for class com.rabbitmq.perf.TimeSequenceMessageBodySource

TimeSequenceMessageBodySource(TimestampProvider, ValueIndicator<Integer>) - Constructor for class com.rabbitmq.perf.TimeSequenceMessageBodySource

TIMESTAMP_HEADER - Static variable in class com.rabbitmq.perf.Producer

TIMESTAMP_PROPERTY - Static variable in class com.rabbitmq.perf.Producer

TimestampProvider - Class in com.rabbitmq.perf

TimestampProvider(boolean, boolean) - Constructor for class com.rabbitmq.perf.TimestampProvider

topologyRecording() - Method in class com.rabbitmq.perf.AgentBase

TopologyRecording - Class in com.rabbitmq.perf

TopologyRecording(boolean, boolean) - Constructor for class com.rabbitmq.perf.TopologyRecording

Create a TopologyRecording with or without polling option.

toString() - Method in class com.rabbitmq.perf.BaseMetrics

toString() - Method in class com.rabbitmq.perf.DatadogMetrics

toString() - Method in class com.rabbitmq.perf.JmxMetrics

toString() - Method in class com.rabbitmq.perf.PrometheusMetrics

type() - Method in class com.rabbitmq.perf.AgentBase

type() - Method in class com.rabbitmq.perf.Consumer

type() - Method in class com.rabbitmq.perf.Producer

TYPE_PROPERTY - Static variable in class com.rabbitmq.perf.Producer

types() - Static method in class com.rabbitmq.perf.metrics.MetricsFormatterFactory

U

USER_ID_PROPERTY - Static variable in class com.rabbitmq.perf.Producer

V

Variable - Interface in com.rabbitmq.perf

VariableValue - Interface in com.rabbitmq.perf

VaryingScenario - Class in com.rabbitmq.perf

VaryingScenario(String, ConnectionFactory, MulticastParams, Variable...) - Constructor for class com.rabbitmq.perf.VaryingScenario

VaryingScenario(String, ConnectionFactory, MulticastParams[], Variable...) - Constructor for class com.rabbitmq.perf.VaryingScenario

VaryingScenarioStats - Class in com.rabbitmq.perf

VaryingScenarioStats() - Constructor for class com.rabbitmq.perf.VaryingScenarioStats

Version - Class in com.rabbitmq.perf

Current version of the tool.

Version() - Constructor for class com.rabbitmq.perf.Version

VERSION - Static variable in class com.rabbitmq.perf.Version

W

waitForCompletion() - Method in interface com.rabbitmq.perf.MulticastSet.CompletionHandler

A B C D E F G H I J L M N O P Q R S T U V W