public class SubscriberSampler extends BaseJMSSampler implements Interruptible, ThreadListener, TestListener
COMMENTS, ENABLED, GUI_CLASS, NAME, TEST_CLASS
Constructor and Description |
---|
SubscriberSampler() |
Modifier and Type | Method and Description |
---|---|
String |
getClientChoice()
Return the client choice.
|
String |
getDurableSubscriptionId() |
String |
getTimeout() |
long |
getTimeoutAsLong() |
boolean |
interrupt()
Handle an interrupt of the test.
|
boolean |
isStopBetweenSamples() |
SampleResult |
sample()
sample method will check which client it should use and call the
appropriate client specific sample method.
|
void |
setClientChoice(String choice)
Set the client choice.
|
void |
setDurableSubscriptionId(String durableSubscriptionId) |
void |
setStopBetweenSamples(boolean selected) |
void |
setTimeout(String timeout) |
void |
testEnded()
Called once for all threads after the end of a test.
|
void |
testEnded(String host)
Called once for all threads after the end of a test.
|
void |
testIterationStart(LoopIterationEvent event)
Each time through a Thread Group's test script, an iteration event is
fired for each thread.
|
void |
testStarted()
Called just before the start of the test from the main engine thread.
|
void |
testStarted(String host)
Called just before the start of the test from the main engine thread.
|
void |
threadFinished()
Close subscriber.
|
void |
threadFinished(boolean wts) |
void |
threadStarted()
Initialise the thread-local variables.
|
void |
threadStarted(boolean wts) |
getConnectionFactory, getDestination, getIterationCount, getIterations, getJNDIInitialContextFactory, getMessageHeaders, getPassword, getProviderUrl, getReadResponse, getReadResponseAsBoolean, getUseJNDIProperties, getUseJNDIPropertiesAsBoolean, getUsername, isDestinationStatic, isUseAuth, sample, setConnectionFactory, setDestination, setDestinationStatic, setIterations, setJNDIIntialContextFactory, setPassword, setProviderUrl, setReadResponse, setUseAuth, setUseJNDIProperties, setUsername
addProperty, addTestElement, canRemove, clear, clearTemporary, clearTestElementChildren, clone, emptyTemporary, equals, getComment, getName, getProperty, getPropertyAsBoolean, getPropertyAsBoolean, getPropertyAsDouble, getPropertyAsFloat, getPropertyAsInt, getPropertyAsInt, getPropertyAsLong, getPropertyAsLong, getPropertyAsString, getPropertyAsString, getThreadContext, getThreadName, hashCode, isEnabled, isRunningVersion, isTemporary, logProperties, mergeIn, propertyIterator, recoverRunningVersion, removeProperty, setComment, setName, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setRunningVersion, setTemporary, setThreadContext, setThreadName, traverse, traverseCollection, traverseMap, traverseProperty
finalize, getClass, notify, notifyAll, toString, wait, wait, wait
addTestElement, canRemove, clear, clearTestElementChildren, clone, getComment, getName, getProperty, getPropertyAsBoolean, getPropertyAsBoolean, getPropertyAsDouble, getPropertyAsFloat, getPropertyAsInt, getPropertyAsInt, getPropertyAsLong, getPropertyAsLong, getPropertyAsString, getPropertyAsString, getThreadContext, getThreadName, isEnabled, isRunningVersion, isTemporary, propertyIterator, recoverRunningVersion, removeProperty, setComment, setName, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setRunningVersion, setTemporary, setThreadContext, setThreadName, traverse
public SampleResult sample()
sample
in class BaseJMSSampler
public void threadStarted()
threadStarted
in interface ThreadListener
JMeterThread.threadStarted()
public void threadStarted(boolean wts)
public void threadFinished()
threadFinished
in interface ThreadListener
JMeterThread.threadFinished(LoopIterationListener)
public void threadFinished(boolean wts)
public boolean interrupt()
interrupt
in interface Interruptible
true
if there was an operation to interrupt.public void setClientChoice(String choice)
public String getClientChoice()
public String getTimeout()
public long getTimeoutAsLong()
public void setTimeout(String timeout)
public String getDurableSubscriptionId()
public void setDurableSubscriptionId(String durableSubscriptionId)
public boolean isStopBetweenSamples()
public void setStopBetweenSamples(boolean selected)
public void testEnded()
Called once for all threads after the end of a test. This will use the same element instances as at the start of the test.
N.B. testStarted() and testEnded() are called from different threads.
testEnded
in interface TestListener
StandardJMeterEngine.stopTest()
public void testEnded(String host)
Called once for all threads after the end of a test. This will use the same element instances as at the start of the test.
N.B. testStarted() and testEnded() are called from different threads.
testEnded
in interface TestListener
host
- name of hostStandardJMeterEngine.stopTest()
public void testIterationStart(LoopIterationEvent event)
testIterationStart
in interface TestListener
public void testStarted()
Called just before the start of the test from the main engine thread. This is before the test elements are cloned. Note that not all the test variables will have been set up at this point.
N.B. testStarted() and testEnded() are called from different threads.
testStarted
in interface TestListener
StandardJMeterEngine.run()
public void testStarted(String host)
Called just before the start of the test from the main engine thread. This is before the test elements are cloned. Note that not all the test variables will have been set up at this point.
N.B. testStarted() and testEnded() are called from different threads.
testStarted
in interface TestListener
host
- name of hostStandardJMeterEngine.run()
Copyright © 1998-2012 Apache Software Foundation. All Rights Reserved.