com.rabbitmq.perf

Class TimeSequenceMessageBodySource

java.lang.Object

com.rabbitmq.perf.TimeSequenceMessageBodySource

All Implemented Interfaces:

MessageBodySource

public class TimeSequenceMessageBodySource
extends java.lang.Object
implements MessageBodySource

Nested Class Summary

Nested classes/interfaces inherited from interface com.rabbitmq.perf.MessageBodySource

MessageBodySource.MessageEnvelope

Constructor Summary

Constructors

Constructor and Description
TimeSequenceMessageBodySource(TimestampProvider tsp, int minMsgSize)
TimeSequenceMessageBodySource(TimestampProvider tsp, com.rabbitmq.perf.ValueIndicator<java.lang.Integer> sizeIndicator)

Method Summary

Modifier and Type	Method and Description
MessageBodySource.MessageEnvelope	create(int sequenceNumber)

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeSequenceMessageBodySource

public TimeSequenceMessageBodySource(TimestampProvider tsp,
                                     int minMsgSize)

TimeSequenceMessageBodySource

public TimeSequenceMessageBodySource(TimestampProvider tsp,
                                     com.rabbitmq.perf.ValueIndicator<java.lang.Integer> sizeIndicator)

Method Detail

create

public MessageBodySource.MessageEnvelope create(int sequenceNumber)
                                         throws java.io.IOException

Specified by:

create in interface MessageBodySource

Throws:

java.io.IOException