Author: sebb
Date: Tue Nov 3 19:16:03 2009
New Revision: 832521
URL: http://svn.apache.org/viewvc?rev=832521&view=rev
Log:
Better handling of received count
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=832521&r1=832520&r2=832521&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:16:03 2009
@@ -162,17 +162,18 @@
}
}
result.sampleEnd();
- 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());
} else {
result.setBytes(this.BUFFER.toString().getBytes().length);
- }
+ }
+ read=this.count(0);
}
result.setSuccessful(true);
- result.setResponseCode(read + " message(s) received successfully");
- result.setSamplerData("Not applicable");
+ result.setResponseCodeOK();
+ result.setResponseMessage(read + " messages received");
+ result.setSamplerData(loop + " messages expected");
result.setSampleCount(read);
this.resetCount();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
