org.springframework.xd.integration.throughput

Class ThroughputSamplerMessageHandler

java.lang.Object

org.springframework.xd.integration.throughput.ThroughputSamplerMessageHandler

All Implemented Interfaces:

org.springframework.messaging.MessageHandler

public class ThroughputSamplerMessageHandler
extends java.lang.Object
implements org.springframework.messaging.MessageHandler

Samples throughput by counting messages over an elapsed time between receiving a Message with the given startMessage and a endMessage and reports the throughput in the given TimeUnit.

Author:

Jon Brisbin

Constructor Summary

Constructors

Constructor and Description
ThroughputSamplerMessageHandler() Create a ThroughputSamplerMessageHandler using the String START as the start message and the String END as the end message and measure throughput in seconds.
ThroughputSamplerMessageHandler(java.lang.Object startMessage, java.lang.Object endMessage, java.util.concurrent.TimeUnit sampleUnit)
ThroughputSamplerMessageHandler(java.lang.String startMessage, java.lang.String endMessage, java.lang.String sampleUnit)

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.Object	getEndMessage()
java.util.concurrent.TimeUnit	getSampleUnit()
java.lang.Object	getStartMessage()
void	handleMessage(org.springframework.messaging.Message<?> message)
void	setEndMessage(java.lang.Object endMessage)
void	setSampleUnit(java.lang.String sampleUnit)
void	setSampleUnit(java.util.concurrent.TimeUnit sampleUnit)
void	setStartMessage(java.lang.Object startMessage)

Methods inherited from class java.lang.Object

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

Constructor Detail

ThroughputSamplerMessageHandler

public ThroughputSamplerMessageHandler()

Create a ThroughputSamplerMessageHandler using the String START as the start message and the String END as the end message and measure throughput in seconds.

ThroughputSamplerMessageHandler

public ThroughputSamplerMessageHandler(java.lang.Object startMessage,
                               java.lang.Object endMessage,
                               java.util.concurrent.TimeUnit sampleUnit)

ThroughputSamplerMessageHandler

public ThroughputSamplerMessageHandler(java.lang.String startMessage,
                               java.lang.String endMessage,
                               java.lang.String sampleUnit)

Method Detail

getStartMessage

public java.lang.Object getStartMessage()

setStartMessage

public void setStartMessage(java.lang.Object startMessage)

getEndMessage

public java.lang.Object getEndMessage()

setEndMessage

public void setEndMessage(java.lang.Object endMessage)

getSampleUnit

public java.util.concurrent.TimeUnit getSampleUnit()

setSampleUnit

public void setSampleUnit(java.lang.String sampleUnit)

setSampleUnit

public void setSampleUnit(java.util.concurrent.TimeUnit sampleUnit)

handleMessage

public void handleMessage(org.springframework.messaging.Message<?> message)
                   throws org.springframework.messaging.MessagingException

Specified by:

handleMessage in interface org.springframework.messaging.MessageHandler

Throws:

org.springframework.messaging.MessagingException