org.gytheio.messaging.benchmark

Class BenchmarkConsumer

java.lang.Object

org.gytheio.messaging.benchmark.BenchmarkConsumer

All Implemented Interfaces:

org.gytheio.messaging.MessageConsumer

public class BenchmarkConsumer
extends Object
implements org.gytheio.messaging.MessageConsumer

Consumer of BenchmarkMessages which maintains a count of messages received.

Author:

Ray Gauss II

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	LOG_AFTER_NUM_MESSAGES

Constructor Summary

Constructors

Constructor and Description
BenchmarkConsumer()

Method Summary

Methods

Modifier and Type	Method and Description
Class<?>	getConsumingMessageBodyClass()
int	getMessageCount()
void	onReceive(Object message)

Methods inherited from class java.lang.Object

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

Field Detail

LOG_AFTER_NUM_MESSAGES

protected static final int LOG_AFTER_NUM_MESSAGES

See Also:

Constant Field Values

Constructor Detail

BenchmarkConsumer

public BenchmarkConsumer()

Method Detail

onReceive

public void onReceive(Object message)

Specified by:

onReceive in interface org.gytheio.messaging.MessageConsumer

getConsumingMessageBodyClass

public Class<?> getConsumingMessageBodyClass()

Specified by:

getConsumingMessageBodyClass in interface org.gytheio.messaging.MessageConsumer

getMessageCount

public int getMessageCount()