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/04/24 19:50:35 UTC
svn commit: r937660 -
/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/Receiver.java
Author: sebb
Date: Sat Apr 24 17:50:34 2010
New Revision: 937660
URL: http://svn.apache.org/viewvc?rev=937660&view=rev
Log:
Code tidy
Modified:
jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/Receiver.java
Modified: jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/Receiver.java
URL: http://svn.apache.org/viewvc/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/Receiver.java?rev=937660&r1=937659&r2=937660&view=diff
==============================================================================
--- jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/Receiver.java (original)
+++ jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/sampler/Receiver.java Sat Apr 24 17:50:34 2010
@@ -73,14 +73,13 @@ public class Receiver implements Runnabl
try {
reply = consumer.receive(5000);
if (reply != null) {
-
- if (log.isDebugEnabled()) {
- log.debug("Received message, correlation id:" + reply.getJMSCorrelationID());
- }
-
- if (reply.getJMSCorrelationID() == null) {
+ final String jmsCorrelationID = reply.getJMSCorrelationID();
+ if (jmsCorrelationID == null) {
log.warn("Received message with correlation id null. Discarding message ...");
} else {
+ if (log.isDebugEnabled()) {
+ log.debug("Received message, correlation id:" + jmsCorrelationID);
+ }
MessageAdmin.getAdmin().putReply(reply.getJMSCorrelationID(), reply);
}
}