svn commit: r941295 - /jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/SubscriberSampler.java

[sebb]

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;
     }