|
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
public class 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,
java.lang.String jndi,
java.lang.String url,
java.lang.String connfactory,
java.lang.String topic,
boolean useAuth,
java.lang.String user,
java.lang.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[] |
java.lang.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, java.lang.String jndi, java.lang.String url, java.lang.String connfactory, java.lang.String topic, boolean useAuth, java.lang.String user, java.lang.String pwd)
Method Detail |
---|
public void setLoop(int loop)
loop
- public void resume()
public java.lang.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 java.lang.Runnable
|
Apache JMeter | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |