B C D E F G H I L M N O P R S U V

B

BenchmarkConsumer - Class in org.gytheio.messaging.benchmark

Consumer of BenchmarkMessages which maintains a count of messages received.

BenchmarkConsumer() - Constructor for class org.gytheio.messaging.benchmark.BenchmarkConsumer

BenchmarkMessage - Class in org.gytheio.messaging.benchmark

A simple message with a decent sized payload for benchmarking.

BenchmarkMessage() - Constructor for class org.gytheio.messaging.benchmark.BenchmarkMessage

BenchmarkRunner - Class in org.gytheio.messaging.benchmark

Runner which creates an AmqpDirectEndpoint or Camel-based endpoint (depending on the brokerUrl given) with a BenchmarkConsumer to measure the throughput of a broker.

BenchmarkRunner(String, String, String, int, boolean, boolean) - Constructor for class org.gytheio.messaging.benchmark.BenchmarkRunner

Bootstrap - Class in org.gytheio.messaging.benchmark

Boostrap which creates and runs a BenchmarkRunner

Bootstrap() - Constructor for class org.gytheio.messaging.benchmark.Bootstrap

BootstrapArguments - Class in org.gytheio.messaging.benchmark

BootstrapArguments() - Constructor for class org.gytheio.messaging.benchmark.BootstrapArguments

brokerUrl - Variable in class org.gytheio.messaging.benchmark.BenchmarkRunner

brokerUrl - Variable in class org.gytheio.messaging.benchmark.BootstrapArguments

C

createInstance() - Static method in class org.gytheio.messaging.benchmark.BenchmarkMessage

D

DEFAULT_ENDPOINT - Static variable in class org.gytheio.messaging.benchmark.BenchmarkRunner

DEFAULT_VALUE - Static variable in class org.gytheio.messaging.benchmark.BenchmarkMessage

E

endpointReceive - Variable in class org.gytheio.messaging.benchmark.BenchmarkRunner

endpointReceive - Variable in class org.gytheio.messaging.benchmark.BootstrapArguments

endpointSend - Variable in class org.gytheio.messaging.benchmark.BenchmarkRunner

endpointSend - Variable in class org.gytheio.messaging.benchmark.BootstrapArguments

equals(Object) - Method in class org.gytheio.messaging.benchmark.BenchmarkMessage

F

formatMillis(long) - Method in class org.gytheio.messaging.benchmark.BenchmarkRunner

Formats a millisecond value for rounded seconds if sufficiently large

G

getBenchmarkConsumer() - Method in class org.gytheio.messaging.benchmark.BenchmarkRunner

getBenchmarkMessage(int) - Method in class org.gytheio.messaging.benchmark.BenchmarkRunner

getConsumingMessageBodyClass() - Method in class org.gytheio.messaging.benchmark.BenchmarkConsumer

getDefaultReceiveEndpoint(String) - Method in class org.gytheio.messaging.benchmark.BenchmarkRunner

getId() - Method in class org.gytheio.messaging.benchmark.BenchmarkMessage

getMessageCount() - Method in class org.gytheio.messaging.benchmark.BenchmarkConsumer

getTimestamp() - Method in class org.gytheio.messaging.benchmark.BenchmarkMessage

getValue() - Method in class org.gytheio.messaging.benchmark.BenchmarkMessage

H

hashCode() - Method in class org.gytheio.messaging.benchmark.BenchmarkMessage

I

initializeAmqpDirectEndpoint(String, String, String, MessageConsumer) - Method in class org.gytheio.messaging.benchmark.BenchmarkRunner

Initializes a Qpid-based AMQP endpoint with no object marshaling with given brokerUrl, endpoint, and messageConsumer.

initializeCamelEndpoint(String, String, String, MessageConsumer) - Method in class org.gytheio.messaging.benchmark.BenchmarkRunner

Initializes a Camel context and configures routes and object marshaling with the given brokerUrl, enpoint, and messageConsumer.

isSupportedEndpoint(String) - Static method in class org.gytheio.messaging.benchmark.Bootstrap

L

LOG_SEPERATOR - Static variable in class org.gytheio.messaging.benchmark.BenchmarkRunner

logAfterNumMessages - Variable in class org.gytheio.messaging.benchmark.BenchmarkConsumer

logAfterNumMessages - Variable in class org.gytheio.messaging.benchmark.BenchmarkRunner

logStart(int, String, String, String, boolean, boolean) - Method in class org.gytheio.messaging.benchmark.BenchmarkRunner

Logs the start of the benchmark to sys out

logStatistics(MessageProducer, BenchmarkConsumer, Object, int, long, long) - Method in class org.gytheio.messaging.benchmark.BenchmarkRunner

Logs the results of the benchmark to sys out

M

main(String[]) - Static method in class org.gytheio.messaging.benchmark.Bootstrap

messageCount - Variable in class org.gytheio.messaging.benchmark.BenchmarkConsumer

N

numMessages - Variable in class org.gytheio.messaging.benchmark.BenchmarkRunner

numMessages - Variable in class org.gytheio.messaging.benchmark.BootstrapArguments

O

onReceive(Object) - Method in class org.gytheio.messaging.benchmark.BenchmarkConsumer

org.gytheio.messaging.benchmark - package org.gytheio.messaging.benchmark

P

parse(String[]) - Static method in class org.gytheio.messaging.benchmark.Bootstrap

R

runBenchmark() - Method in class org.gytheio.messaging.benchmark.BenchmarkRunner

runConsumer - Variable in class org.gytheio.messaging.benchmark.BenchmarkRunner

runConsumer - Variable in class org.gytheio.messaging.benchmark.BootstrapArguments

runProducer - Variable in class org.gytheio.messaging.benchmark.BenchmarkRunner

runProducer - Variable in class org.gytheio.messaging.benchmark.BootstrapArguments

S

setId(String) - Method in class org.gytheio.messaging.benchmark.BenchmarkMessage

setLogAfterNumMessages(int) - Method in class org.gytheio.messaging.benchmark.BenchmarkConsumer

setTimestamp(long) - Method in class org.gytheio.messaging.benchmark.BenchmarkMessage

setValue(String) - Method in class org.gytheio.messaging.benchmark.BenchmarkMessage

U

USAGE_MESSAGE - Static variable in class org.gytheio.messaging.benchmark.Bootstrap

V

validateMessage(Object) - Method in class org.gytheio.messaging.benchmark.BenchmarkConsumer

B C D E F G H I L M N O P R S U V