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/06/22 23:58:08 UTC
svn commit: r957048 -
/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/PublisherSampler.java
Author: sebb
Date: Tue Jun 22 21:58:07 2010
New Revision: 957048
URL: http://svn.apache.org/viewvc?rev=957048&view=rev
Log:
Tidyup output
Modified:
jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/PublisherSampler.java
Modified: jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/PublisherSampler.java
URL: http://svn.apache.org/viewvc/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/PublisherSampler.java?rev=957048&r1=957047&r2=957048&view=diff
==============================================================================
--- jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/PublisherSampler.java (original)
+++ jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/PublisherSampler.java Tue Jun 22 21:58:07 2010
@@ -135,34 +135,31 @@ public class PublisherSampler extends Ba
result.setSampleLabel(getName());
result.setSuccessful(false); // Assume it will fail
result.setResponseCode("000"); // ditto $NON-NLS-1$
- result.setResponseMessage("See log file for details"); // ditto
if (publisher == null) {
try {
initClient();
} catch (JMSException e) {
- log.warn("Could not create client", e);
+ result.setResponseMessage(e.toString());
+ return result;
} catch (NamingException e) {
- log.warn("Could not create client", e);
+ result.setResponseMessage(e.toString());
+ return result;
}
}
StringBuilder buffer = new StringBuilder();
int loop = getIterationCount();
result.sampleStart();
try {
- if (publisher != null) {
- for (int idx = 0; idx < loop; idx++) {
- String tmsg = getMessageContent();
- publisher.publish(tmsg);
- buffer.append(tmsg);
- }
- result.setResponseCodeOK();
- result.setResponseMessage(loop + " messages published");
- result.setSuccessful(true);
- result.setSamplerData(buffer.toString());
- result.setSampleCount(loop);
- } else {
- result.setResponseMessage("Publisher not available - see log file");
+ for (int idx = 0; idx < loop; idx++) {
+ String tmsg = getMessageContent();
+ publisher.publish(tmsg);
+ buffer.append(tmsg);
}
+ result.setResponseCodeOK();
+ result.setResponseMessage(loop + " messages published");
+ result.setSuccessful(true);
+ result.setSamplerData(buffer.toString());
+ result.setSampleCount(loop);
} catch (Exception e) {
result.setResponseMessage(e.toString());
} finally {
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@jakarta.apache.org
For additional commands, e-mail: notifications-help@jakarta.apache.org