public class MongoSourceElement extends ConfigTestElement implements TestStateListener, TestBean
PASSWORD, USERNAME
COMMENTS, ENABLED, GUI_CLASS, NAME, TEST_CLASS
Constructor and Description |
---|
MongoSourceElement() |
Modifier and Type | Method and Description |
---|---|
void |
addConfigElement(ConfigElement configElement)
Add a configuration element to this one.
|
boolean |
expectsModification()
If your config element expects to be modified in the process of a test
run, and you want those modifications to carry over from sample to sample
(as in a cookie manager - you want to save all cookies that get set
throughout the test), then return true for this method.
|
boolean |
getAutoConnectRetry() |
String |
getConnection() |
int |
getConnectionsPerHost() |
int |
getConnectTimeout() |
boolean |
getContinueOnInsertError() |
boolean |
getFsync() |
long |
getMaxAutoConnectRetryTime() |
int |
getMaxWaitTime() |
static MongoDB |
getMongoDB(String source) |
boolean |
getSafe() |
boolean |
getSocketKeepAlive() |
int |
getSocketTimeout() |
String |
getSource() |
int |
getThreadsAllowedToBlockForConnectionMultiplier() |
String |
getTitle() |
boolean |
getWaitForJournaling() |
int |
getWriteOperationNumberOfServers() |
int |
getWriteOperationTimeout() |
void |
setAutoConnectRetry(boolean autoConnectRetry) |
void |
setConnection(String connection) |
void |
setConnectionsPerHost(int connectionsPerHost) |
void |
setConnectTimeout(int connectTimeout) |
void |
setContinueOnInsertError(boolean continueOnInsertError) |
void |
setFsync(boolean fsync) |
void |
setMaxAutoConnectRetryTime(long maxAutoConnectRetryTime) |
void |
setMaxWaitTime(int maxWaitTime) |
void |
setSafe(boolean safe) |
void |
setSocketKeepAlive(boolean socketKeepAlive) |
void |
setSocketTimeout(int socketTimeout) |
void |
setSource(String source) |
void |
setThreadsAllowedToBlockForConnectionMultiplier(int threadsAllowedToBlockForConnectionMultiplier) |
void |
setWaitForJournaling(boolean waitForJournaling) |
void |
setWriteOperationNumberOfServers(int writeOperationNumberOfServers) |
void |
setWriteOperationTimeout(int writeOperationTimeout) |
void |
testEnded()
Called once for all threads after the end of a test.
|
void |
testEnded(String s)
Called once for all threads after the end of a test.
|
void |
testStarted()
Called just before the start of the test from the main engine thread.
|
void |
testStarted(String s)
Called just before the start of the test from the main engine thread.
|
addTestElement
addPropertiesValues, addProperty, addProperty, canRemove, clear, clearTemporary, clearTestElementChildren, clone, emptyTemporary, equals, getComment, getName, getProperty, getPropertyAsBoolean, getPropertyAsBoolean, getPropertyAsDouble, getPropertyAsFloat, getPropertyAsInt, getPropertyAsInt, getPropertyAsLong, getPropertyAsLong, getPropertyAsString, getPropertyAsString, getSearchableTokens, getThreadContext, getThreadName, hashCode, isEnabled, isRunningVersion, isTemporary, logProperties, mergeIn, propertyIterator, recoverRunningVersion, removeProperty, setComment, setEnabled, setName, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setRunningVersion, setTemporary, setThreadContext, setThreadName, traverse, traverseCollection, traverseMap, traverseProperty
finalize, getClass, notify, notifyAll, toString, wait, wait, wait
clone
removed
public String getTitle()
public String getConnection()
public void setConnection(String connection)
public String getSource()
public void setSource(String source)
public void addConfigElement(ConfigElement configElement)
ConfigTestElement
addConfigElement
in interface ConfigElement
addConfigElement
in class ConfigTestElement
configElement
- the element to be added to this ConfigElementpublic boolean expectsModification()
ConfigTestElement
expectsModification
in interface ConfigElement
expectsModification
in class ConfigTestElement
public void testStarted()
TestStateListener
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 TestStateListener
StandardJMeterEngine.run()
public void testStarted(String s)
TestStateListener
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 TestStateListener
s
- name of hostStandardJMeterEngine.run()
public void testEnded()
TestStateListener
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 TestStateListener
StandardJMeterEngine.stopTest()
public void testEnded(String s)
TestStateListener
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 TestStateListener
s
- name of hostStandardJMeterEngine.stopTest()
public boolean getAutoConnectRetry()
public void setAutoConnectRetry(boolean autoConnectRetry)
autoConnectRetry
- the autoConnectRetry to setpublic int getConnectionsPerHost()
public void setConnectionsPerHost(int connectionsPerHost)
connectionsPerHost
- the connectionsPerHost to setpublic int getConnectTimeout()
public void setConnectTimeout(int connectTimeout)
connectTimeout
- the connectTimeout to setpublic long getMaxAutoConnectRetryTime()
public void setMaxAutoConnectRetryTime(long maxAutoConnectRetryTime)
maxAutoConnectRetryTime
- the maxAutoConnectRetryTime to setpublic int getMaxWaitTime()
public void setMaxWaitTime(int maxWaitTime)
maxWaitTime
- the maxWaitTime to setpublic int getSocketTimeout()
public void setSocketTimeout(int socketTimeout)
socketTimeout
- the socketTimeout to setpublic boolean getSocketKeepAlive()
public void setSocketKeepAlive(boolean socketKeepAlive)
socketKeepAlive
- the socketKeepAlive to setpublic int getThreadsAllowedToBlockForConnectionMultiplier()
public void setThreadsAllowedToBlockForConnectionMultiplier(int threadsAllowedToBlockForConnectionMultiplier)
threadsAllowedToBlockForConnectionMultiplier
- the threadsAllowedToBlockForConnectionMultiplier to setpublic boolean getFsync()
public void setFsync(boolean fsync)
fsync
- the fsync to setpublic boolean getSafe()
public void setSafe(boolean safe)
safe
- the safe to setpublic boolean getWaitForJournaling()
public void setWaitForJournaling(boolean waitForJournaling)
waitForJournaling
- the waitForJournaling to setpublic int getWriteOperationNumberOfServers()
public void setWriteOperationNumberOfServers(int writeOperationNumberOfServers)
writeOperationNumberOfServers
- the writeOperationNumberOfServers to setpublic int getWriteOperationTimeout()
public void setWriteOperationTimeout(int writeOperationTimeout)
writeOperationTimeout
- the writeOperationTimeout to setpublic boolean getContinueOnInsertError()
public void setContinueOnInsertError(boolean continueOnInsertError)
continueOnInsertError
- the continueOnInsertError to setCopyright © 1998-2019 Apache Software Foundation. All Rights Reserved.