|
Apache JMeter | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.jmeter.protocol.jms.client.ReceiveSubscriber
Receives messages in a separate thread until told to stop. Run loop permanently receives messages; the sampler calls reset() when it has taken enough messages.
Constructor Summary | |
ReceiveSubscriber(boolean useProps,
String jndi,
String url,
String connfactory,
String topic,
boolean useAuth,
String user,
String pwd)
|
Method Summary | |
void |
close()
close() will stop the connection first. |
int |
count(int increment)
Increment the count and return the new value |
byte[] |
getByteResult()
Get the message(s) as an array of byte[] |
String |
getMessage()
Get the message as a string |
void |
reset()
Reset the receiver ready for receiving any further messages |
void |
resume()
Resume will call Connection.start() and begin receiving messages from the JMS provider. |
void |
run()
run calls listen to begin listening for inbound messages from the provider. |
void |
setLoop(int loop)
Set the number of iterations for each call to sample() |
void |
start()
start will create a new thread and pass this class. once the thread is created, it calls Thread.start(). |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public ReceiveSubscriber(boolean useProps, String jndi, String url, String connfactory, String topic, boolean useAuth, String user, String pwd)
Method Detail |
public void setLoop(int loop)
loop
- public void resume()
public String getMessage()
public byte[] getByteResult()
public void close()
public void reset()
public int count(int increment)
increment
- public void start()
public void run()
run
in interface Runnable
|
Apache JMeter | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |