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 int	logAfterNumMessages
protected int	messageCount

Constructor Summary

Constructors

Constructor and Description
BenchmarkConsumer()

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Field Detail

logAfterNumMessages

protected int logAfterNumMessages

messageCount

protected int messageCount

Constructor Detail

BenchmarkConsumer

public BenchmarkConsumer()

Method Detail

setLogAfterNumMessages

public void setLogAfterNumMessages(int logAfterNumMessages)

onReceive

public void onReceive(Object message)

Specified by:

onReceive in interface org.gytheio.messaging.MessageConsumer

validateMessage

protected void validateMessage(Object message)

getConsumingMessageBodyClass

public Class<?> getConsumingMessageBodyClass()

Specified by:

getConsumingMessageBodyClass in interface org.gytheio.messaging.MessageConsumer

getMessageCount

public int getMessageCount()