You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@jakarta.apache.org by se...@apache.org on 2010/05/05 16:02:42 UTC
svn commit: r941295 -
/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/SubscriberSampler.java
Author: sebb
Date: Wed May 5 14:02:42 2010
New Revision: 941295
URL: http://svn.apache.org/viewvc?rev=941295&view=rev
Log:
Count messages actually read
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=941295&r1=941294&r2=941295&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 Wed May 5 14:02:42 2010
@@ -169,9 +169,11 @@ public class SubscriberSampler extends B
}
result.sampleEnd();
+ int read = 0;
for(cnt = 0; cnt < loop ; cnt++) {
TextMessage msg = queue.poll();
if (msg != null) {
+ read++;
try {
buffer.append(msg.getText());
Enumeration<?> props = msg.getPropertyNames();
@@ -197,9 +199,9 @@ public class SubscriberSampler extends B
result.setDataType(SampleResult.TEXT);
result.setSuccessful(true);
result.setResponseCodeOK();
- result.setResponseMessage(loop + " messages received"); // TODO fix
+ result.setResponseMessage(read + " messages received");
result.setSamplerData(loop + " messages expected");
- result.setSampleCount(loop);
+ result.setSampleCount(read);
return result;
}