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: jmeter-dev-unsubscr...@jakarta.apache.org For additional commands, e-mail: jmeter-dev-h...@jakarta.apache.org