Class MongoSourceElement

    • Constructor Detail

      • MongoSourceElement

        public MongoSourceElement()
    • Method Detail

      • getTitle

        public String getTitle()
      • getConnection

        public String getConnection()
      • setConnection

        public void setConnection​(String connection)
      • getSource

        public String getSource()
      • setSource

        public void setSource​(String source)
      • getMongoDB

        public static MongoDB getMongoDB​(String source)
      • addConfigElement

        public void addConfigElement​(ConfigElement configElement)
        Description copied from class: ConfigTestElement
        Add a configuration element to this one. This allows config elements to combine and give a "layered" effect. For example, HTTPConfigElements have properties for domain, path, method, and parameters. If element A has everything filled in, but null for domain, and element B is added, which has only domain filled in, then after adding B to A, A will have the domain from B. If A already had a domain, then the correct behavior is for A to ignore the addition of element B.
        Specified by:
        addConfigElement in interface ConfigElement
        Overrides:
        addConfigElement in class ConfigTestElement
        Parameters:
        configElement - the element to be added to this ConfigElement
      • expectsModification

        public boolean expectsModification()
        Description copied from class: ConfigTestElement
        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. Your config element will not be cloned for each sample. If your config elements are more static in nature, return false. If in doubt, return false.
        Specified by:
        expectsModification in interface ConfigElement
        Overrides:
        expectsModification in class ConfigTestElement
        Returns:
        true if the element expects to be modified over the course of a test run
      • testStarted

        public void testStarted()
        Description copied from interface: 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.

        Specified by:
        testStarted in interface TestStateListener
        See Also:
        StandardJMeterEngine.run()
      • testStarted

        public void testStarted​(String s)
        Description copied from interface: 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.

        Specified by:
        testStarted in interface TestStateListener
        Parameters:
        s - name of host
        See Also:
        StandardJMeterEngine.run()
      • testEnded

        public void testEnded()
        Description copied from interface: 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.

        Specified by:
        testEnded in interface TestStateListener
        See Also:
        StandardJMeterEngine.stopTest()
      • testEnded

        public void testEnded​(String s)
        Description copied from interface: 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.

        Specified by:
        testEnded in interface TestStateListener
        Parameters:
        s - name of host
        See Also:
        StandardJMeterEngine.stopTest()
      • getAutoConnectRetry

        public boolean getAutoConnectRetry()
        Returns:
        the autoConnectRetry
      • setAutoConnectRetry

        public void setAutoConnectRetry​(boolean autoConnectRetry)
        Parameters:
        autoConnectRetry - the autoConnectRetry to set
      • getConnectionsPerHost

        public int getConnectionsPerHost()
        Returns:
        the connectionsPerHost
      • setConnectionsPerHost

        public void setConnectionsPerHost​(int connectionsPerHost)
        Parameters:
        connectionsPerHost - the connectionsPerHost to set
      • getConnectTimeout

        public int getConnectTimeout()
        Returns:
        the connectTimeout
      • setConnectTimeout

        public void setConnectTimeout​(int connectTimeout)
        Parameters:
        connectTimeout - the connectTimeout to set
      • getMaxAutoConnectRetryTime

        public long getMaxAutoConnectRetryTime()
        Returns:
        the maxAutoConnectRetryTime
      • setMaxAutoConnectRetryTime

        public void setMaxAutoConnectRetryTime​(long maxAutoConnectRetryTime)
        Parameters:
        maxAutoConnectRetryTime - the maxAutoConnectRetryTime to set
      • getMaxWaitTime

        public int getMaxWaitTime()
        Returns:
        the maxWaitTime
      • setMaxWaitTime

        public void setMaxWaitTime​(int maxWaitTime)
        Parameters:
        maxWaitTime - the maxWaitTime to set
      • getSocketTimeout

        public int getSocketTimeout()
        Returns:
        the socketTimeout
      • setSocketTimeout

        public void setSocketTimeout​(int socketTimeout)
        Parameters:
        socketTimeout - the socketTimeout to set
      • getSocketKeepAlive

        public boolean getSocketKeepAlive()
        Returns:
        the socketKeepAlive
      • setSocketKeepAlive

        public void setSocketKeepAlive​(boolean socketKeepAlive)
        Parameters:
        socketKeepAlive - the socketKeepAlive to set
      • getThreadsAllowedToBlockForConnectionMultiplier

        public int getThreadsAllowedToBlockForConnectionMultiplier()
        Returns:
        the threadsAllowedToBlockForConnectionMultiplier
      • setThreadsAllowedToBlockForConnectionMultiplier

        public void setThreadsAllowedToBlockForConnectionMultiplier​(int threadsAllowedToBlockForConnectionMultiplier)
        Parameters:
        threadsAllowedToBlockForConnectionMultiplier - the threadsAllowedToBlockForConnectionMultiplier to set
      • getFsync

        public boolean getFsync()
        Returns:
        the fsync
      • setFsync

        public void setFsync​(boolean fsync)
        Parameters:
        fsync - the fsync to set
      • getSafe

        public boolean getSafe()
        Returns:
        the safe
      • setSafe

        public void setSafe​(boolean safe)
        Parameters:
        safe - the safe to set
      • getWaitForJournaling

        public boolean getWaitForJournaling()
        Returns:
        the waitForJournaling
      • setWaitForJournaling

        public void setWaitForJournaling​(boolean waitForJournaling)
        Parameters:
        waitForJournaling - the waitForJournaling to set
      • getWriteOperationNumberOfServers

        public int getWriteOperationNumberOfServers()
        Returns:
        the writeOperationNumberOfServers
      • setWriteOperationNumberOfServers

        public void setWriteOperationNumberOfServers​(int writeOperationNumberOfServers)
        Parameters:
        writeOperationNumberOfServers - the writeOperationNumberOfServers to set
      • getWriteOperationTimeout

        public int getWriteOperationTimeout()
        Returns:
        the writeOperationTimeout
      • setWriteOperationTimeout

        public void setWriteOperationTimeout​(int writeOperationTimeout)
        Parameters:
        writeOperationTimeout - the writeOperationTimeout to set
      • getContinueOnInsertError

        public boolean getContinueOnInsertError()
        Returns:
        the continueOnInsertError
      • setContinueOnInsertError

        public void setContinueOnInsertError​(boolean continueOnInsertError)
        Parameters:
        continueOnInsertError - the continueOnInsertError to set