org.gytheio.messaging.benchmark

Class BenchmarkRunner

java.lang.Object

org.gytheio.messaging.benchmark.BenchmarkRunner

public class BenchmarkRunner
extends Object

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

brokerUrl beginning with:

• tcp: creates a Camel-based endpoint using JSON object marshaling/unmarshaling
• amqp: creates an AmqpDirectEndpoint without object marshaling

Author:

Ray Gauss II

Field Summary

Fields

Modifier and Type	Field and Description
protected String	brokerUrl
protected static String	DEFAULT_ENDPOINT
protected String	endpointReceive
protected String	endpointSend
protected static String	LOG_SEPERATOR
protected int	logAfterNumMessages
protected int	numMessages
protected boolean	runConsumer
protected boolean	runProducer

Constructor Summary

Constructors

Constructor and Description
BenchmarkRunner(String brokerUrl, String endpointSend, String endpointReceive, int numMessages, boolean runProducer, boolean runConsumer)

Method Summary

Methods

Modifier and Type	Method and Description
protected String	formatMillis(long milliseconds) Formats a millisecond value for rounded seconds if sufficiently large
protected BenchmarkConsumer	getBenchmarkConsumer()
protected Object	getBenchmarkMessage(int i)
protected String	getDefaultReceiveEndpoint(String endpointSend)
protected org.gytheio.messaging.MessageProducer	initializeAmqpDirectEndpoint(String brokerUrl, String endpointSend, String endpointReceive, org.gytheio.messaging.MessageConsumer messageConsumer) Initializes a Qpid-based AMQP endpoint with no object marshaling with given brokerUrl, endpoint, and messageConsumer.
protected org.gytheio.messaging.MessageProducer	initializeCamelEndpoint(String brokerUrl, String endpointSend, String endpointReceive, org.gytheio.messaging.MessageConsumer messageConsumer) Initializes a Camel context and configures routes and object marshaling with the given brokerUrl, enpoint, and messageConsumer.
protected void	logStart(int numMessages, String brokerUrl, String endpointSend, String endpointReceive, boolean runProducer, boolean runConsumer) Logs the start of the benchmark to sys out
protected void	logStatistics(org.gytheio.messaging.MessageProducer endpoint, BenchmarkConsumer consumer, Object message, int numMessages, long sendTime, long receiveTime) Logs the results of the benchmark to sys out
void	runBenchmark()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_ENDPOINT

protected static final String DEFAULT_ENDPOINT

See Also:

Constant Field Values

LOG_SEPERATOR

protected static final String LOG_SEPERATOR

See Also:

Constant Field Values

logAfterNumMessages

protected int logAfterNumMessages

brokerUrl

protected String brokerUrl

endpointSend

protected String endpointSend

endpointReceive

protected String endpointReceive

numMessages

protected int numMessages

runProducer

protected boolean runProducer

runConsumer

protected boolean runConsumer

Constructor Detail

BenchmarkRunner

public BenchmarkRunner(String brokerUrl,
               String endpointSend,
               String endpointReceive,
               int numMessages,
               boolean runProducer,
               boolean runConsumer)

Method Detail

getDefaultReceiveEndpoint

protected String getDefaultReceiveEndpoint(String endpointSend)

getBenchmarkMessage

protected Object getBenchmarkMessage(int i)

getBenchmarkConsumer

protected BenchmarkConsumer getBenchmarkConsumer()

runBenchmark

public void runBenchmark()
                  throws Exception

Throws:

Exception

initializeCamelEndpoint

protected org.gytheio.messaging.MessageProducer initializeCamelEndpoint(String brokerUrl,
                                                            String endpointSend,
                                                            String endpointReceive,
                                                            org.gytheio.messaging.MessageConsumer messageConsumer)
                                                                 throws Exception

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

Parameters:

brokerUrl -

endpoint -

messageConsumer -

Returns:

the Gytheio message producer

Throws:

Exception

initializeAmqpDirectEndpoint

protected org.gytheio.messaging.MessageProducer initializeAmqpDirectEndpoint(String brokerUrl,
                                                                 String endpointSend,
                                                                 String endpointReceive,
                                                                 org.gytheio.messaging.MessageConsumer messageConsumer)

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

Parameters:

brokerUrl -

endpoint -

messageConsumer -

Returns:

the Gytheio message producer

logStart

protected void logStart(int numMessages,
            String brokerUrl,
            String endpointSend,
            String endpointReceive,
            boolean runProducer,
            boolean runConsumer)

Logs the start of the benchmark to sys out

Parameters:

numMessages -

brokerUrl -

endpoint -

logStatistics

protected void logStatistics(org.gytheio.messaging.MessageProducer endpoint,
                 BenchmarkConsumer consumer,
                 Object message,
                 int numMessages,
                 long sendTime,
                 long receiveTime)

Logs the results of the benchmark to sys out

Parameters:

endpoint -

numMessages -

sendTime -

receiveTime -

formatMillis

protected String formatMillis(long milliseconds)

Formats a millisecond value for rounded seconds if sufficiently large

Parameters:

milliseconds -

Returns:

the string representation of the given time