| java.lang.Object
 org.apache.jmeter.protocol.jms.client.ReceiveSubscriber
| ReceiveSubscriber | | public class ReceiveSubscriber implements Runnable(Code) | | |
| Method Summary | |
| public void | clear()
Clear will set the buffer to zero and the result objects to null. | | public synchronized void | close()
close() will stop the connection first. | | public synchronized int | count(int increment)
| | public byte[] | getByteResult()
| | public String | getMessage()
| | public void | initConnection(Context ctx, String connfactory, String topic)
| | public Context | initJNDI(boolean useProps, String jndi, String url, String useAuth, String user, String pwd)
| | protected void | listen()
| | public synchronized int | resetCount()
Reset will reset the counter and prepare for the next sample() call. | | public void | resume()
Resume will call Connection.start() and begin receiving messages from the
JMS provider. | | public void | run()
run calls listen to begin listening for inboud messages from the
provider. | | public void | setLoop(int loop)
| | public void | start()
start will create a new thread and pass this class. |
| ReceiveSubscriber | | public ReceiveSubscriber()(Code) | | |
| clear | | public void clear()(Code) | | Clear will set the buffer to zero and the result objects to null. Clear
should be called at the end of a sample.
|
| close | | public synchronized void close()(Code) | | close() will stop the connection first. Then it closes the subscriber,
session and connection and sets them to null.
|
| count | | public synchronized int count(int increment)(Code) | | Increment the count and return the new value
Parameters:
increment - |
| getByteResult | | public byte[] getByteResult()(Code) | | Get the message(s) as an array of byte[]
|
| getMessage | | public String getMessage()(Code) | | Get the message as a string
|
| initConnection | | public void initConnection(Context ctx, String connfactory, String topic)(Code) | | Create the connection, session and topic subscriber
Parameters:
ctx -
Parameters:
connfactory -
Parameters:
topic - |
| initJNDI | | public Context initJNDI(boolean useProps, String jndi, String url, String useAuth, String user, String pwd)(Code) | | Initialize the JNDI initial context
Parameters:
useProps -
Parameters:
jndi -
Parameters:
url -
Parameters:
useAuth -
Parameters:
user -
Parameters:
pwd - the JNDI initial context or null |
| listen | | protected void listen()(Code) | | Listen for inbound messages
|
| resetCount | | public synchronized int resetCount()(Code) | | Reset will reset the counter and prepare for the next sample() call.
|
| resume | | public void resume()(Code) | | Resume will call Connection.start() and begin receiving messages from the
JMS provider.
|
| run | | public void run()(Code) | | run calls listen to begin listening for inboud messages from the
provider.
|
| setLoop | | public void setLoop(int loop)(Code) | | Set the number of iterations for each call to sample()
Parameters:
loop - |
| start | | public void start()(Code) | | start will create a new thread and pass this class. once the thread is
created, it calls Thread.start().
|
|
|