Apache JMeter

org.apache.jmeter.protocol.jms.client
Class ReceiveSubscriber

java.lang.Object
  extended by org.apache.jmeter.protocol.jms.client.ReceiveSubscriber
All Implemented Interfaces:
java.lang.Runnable

public class ReceiveSubscriber
extends java.lang.Object
implements java.lang.Runnable

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

ReceiveSubscriber

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

setLoop

public void setLoop(int loop)
Set the number of iterations for each call to sample()

Parameters:
loop -

resume

public void resume()
Resume will call Connection.start() and begin receiving messages from the JMS provider.


getMessage

public java.lang.String getMessage()
Get the message as a string


getByteResult

public byte[] getByteResult()
Get the message(s) as an array of byte[]


close

public void close()
close() will stop the connection first. Then it closes the subscriber, session and connection.


reset

public void reset()
Reset the receiver ready for receiving any further messages


count

public int count(int increment)
Increment the count and return the new value

Parameters:
increment -

start

public void start()
start will create a new thread and pass this class. once the thread is created, it calls Thread.start().


run

public void run()
run calls listen to begin listening for inbound messages from the provider. Updates the count field so the caller can check how many messages have been receieved.

Specified by:
run in interface java.lang.Runnable

Apache JMeter

Copyright © 1998-2009 Apache Software Foundation. All Rights Reserved.