You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jmeter-dev@jakarta.apache.org by se...@apache.org on 2009/11/03 20:02:38 UTC
svn commit: r832512 -
/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/SubscriberSampler.java
Author: sebb
Date: Tue Nov 3 19:02:38 2009
New Revision: 832512
URL: http://svn.apache.org/viewvc?rev=832512&view=rev
Log:
Actual count may be lower than loop when interrupted
Modified:
jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/SubscriberSampler.java
Modified: jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/SubscriberSampler.java
URL: http://svn.apache.org/viewvc/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/SubscriberSampler.java?rev=832512&r1=832511&r2=832512&view=diff
==============================================================================
--- jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/SubscriberSampler.java (original)
+++ jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/SubscriberSampler.java Tue Nov 3 19:02:38 2009
@@ -153,7 +153,8 @@
int loop = this.getIterationCount();
result.sampleStart();
- while (this.count(0) < loop && interrupted == false) {
+ int read;
+ while ((read=this.count(0)) < loop && interrupted == false) {
try {
Thread.sleep(0, 50);
} catch (InterruptedException e) {
@@ -161,7 +162,7 @@
}
}
result.sampleEnd();
- result.setResponseMessage(loop + " samples messages received");
+ result.setResponseMessage(read + " samples messages received");
synchronized (this) {// Need to synch because buffer is shared with onMessageHandler
if (this.getReadResponseAsBoolean()) {
result.setResponseData(this.BUFFER.toString().getBytes());
@@ -170,9 +171,9 @@
}
}
result.setSuccessful(true);
- result.setResponseCode(loop + " message(s) received successfully");
+ result.setResponseCode(read + " message(s) received successfully");
result.setSamplerData("Not applicable");
- result.setSampleCount(loop);
+ result.setSampleCount(read);
this.resetCount();
return result;
---------------------------------------------------------------------
To unsubscribe, e-mail: jmeter-dev-unsubscribe@jakarta.apache.org
For additional commands, e-mail: jmeter-dev-help@jakarta.apache.org