public class ConsumerParticipant extends Object implements Participant
Constructor and Description |
---|
ConsumerParticipant(ClientJmsDelegate delegate,
CreateConsumerCommand command) |
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() |
public ConsumerParticipant(ClientJmsDelegate delegate, CreateConsumerCommand command)
public void startTest(String registeredClientName, org.apache.qpid.disttest.client.ResultReporter resultReporter) throws Exception
startTest
in interface Participant
Exception
public void startDataCollection()
startDataCollection
in interface Participant
public void stopTest()
stopTest
in interface Participant
public void processAsyncMessage(javax.jms.Message message)
MessageListener
. Updates _asyncRunHasFinished
if
no more messages should be processed, causing Participant.startTest(String, ResultReporter)
to exit.public void releaseResources()
releaseResources
in interface Participant
public String getName()
getName
in interface Participant
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.