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

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

Bootstrap - Class in org.gytheio.messaging.benchmark

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

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

C

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

D

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

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

E

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

F

formatMillis(long) - Static method in class org.gytheio.messaging.benchmark.Bootstrap

Formats a millisecond value for rounded seconds if sufficientaly large

G

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

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, MessageConsumer) - Static method in class org.gytheio.messaging.benchmark.Bootstrap

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

initializeCamelEndpoint(String, String, MessageConsumer) - Static method in class org.gytheio.messaging.benchmark.Bootstrap

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

L

LOG_AFTER_NUM_MESSAGES - Static variable in class org.gytheio.messaging.benchmark.BenchmarkConsumer

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

logStart(int, String, String, boolean, boolean) - Static method in class org.gytheio.messaging.benchmark.Bootstrap

Logs the start of the benchmark to sys out

logStatistics(MessageProducer, int, long, long) - Static method in class org.gytheio.messaging.benchmark.Bootstrap

Logs the results of the benchmark to sys out

M

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

O

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

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

R

runBenchmark(String, String, int, boolean, boolean) - Static method in class org.gytheio.messaging.benchmark.Bootstrap

S

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

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

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