org.apache.qpid.disttest.client

Class ConsumerParticipant

java.lang.Object

org.apache.qpid.disttest.client.ConsumerParticipant

All Implemented Interfaces:

Participant

public class ConsumerParticipant
extends Object
implements Participant

Constructor Summary

Constructors

Constructor and Description
ConsumerParticipant(ClientJmsDelegate delegate, CreateConsumerCommand command)

Method Summary

Modifier and Type	Method and Description
String	getName()
void	processAsyncMessage(javax.jms.Message message) Intended to be called from a MessageListener.
void	releaseResources()
void	startDataCollection()
void	startTest(String registeredClientName, org.apache.qpid.disttest.client.ResultReporter resultReporter)
void	stopTest()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerParticipant

public ConsumerParticipant(ClientJmsDelegate delegate,
                           CreateConsumerCommand command)

Method Detail

startTest

public void startTest(String registeredClientName,
                      org.apache.qpid.disttest.client.ResultReporter resultReporter)
               throws Exception

Specified by:

startTest in interface Participant

Throws:

Exception

startDataCollection

public void startDataCollection()

Specified by:

startDataCollection in interface Participant

stopTest

public void stopTest()

Specified by:

stopTest in interface Participant

processAsyncMessage

public void processAsyncMessage(javax.jms.Message message)

Intended to be called from a MessageListener. Updates _asyncRunHasFinished if no more messages should be processed, causing Participant.startTest(String, ResultReporter) to exit.

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface Participant

getName

public String getName()

Specified by:

getName in interface Participant

toString

public String toString()

Overrides:

toString in class Object