org.gytheio.messaging.benchmark

Class Bootstrap

java.lang.Object

org.gytheio.messaging.benchmark.Bootstrap

public class Bootstrap
extends Object

Boostrap 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 static String	DEFAULT_ENDPOINT
protected static String	LOG_SEPERATOR
protected static String	USAGE_MESSAGE

Constructor Summary

Constructors

Constructor and Description
Bootstrap()

Method Summary

Methods

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

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

USAGE_MESSAGE

protected static final String USAGE_MESSAGE

See Also:

Constant Field Values

LOG_SEPERATOR

protected static final String LOG_SEPERATOR

See Also:

Constant Field Values

Constructor Detail

Bootstrap

public Bootstrap()

Method Detail

main

public static void main(String[] args)

runBenchmark

protected static void runBenchmark(String brokerUrl,
                String endpoint,
                int numMessages,
                boolean runProducer,
                boolean runConsumer)
                            throws Exception

Throws:

Exception

initializeCamelEndpoint

protected static org.gytheio.messaging.MessageProducer initializeCamelEndpoint(String brokerUrl,
                                                            String endpoint,
                                                            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 static org.gytheio.messaging.MessageProducer initializeAmqpDirectEndpoint(String brokerUrl,
                                                                 String endpoint,
                                                                 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 static void logStart(int numMessages,
            String brokerUrl,
            String endpoint,
            boolean runProducer,
            boolean runConsumer)

Logs the start of the benchmark to sys out

Parameters:

numMessages -

brokerUrl -

endpoint -

logStatistics

protected static void logStatistics(org.gytheio.messaging.MessageProducer endpoint,
                 int numMessages,
                 long sendTime,
                 long receiveTime)

Logs the results of the benchmark to sys out

Parameters:

endpoint -

numMessages -

sendTime -

receiveTime -

formatMillis

protected static String formatMillis(long milliseconds)

Formats a millisecond value for rounded seconds if sufficientaly large

Parameters:

milliseconds -

Returns:

the string representation of the given time