Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add some more detailed logging 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@937308 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2010-04-23 14:12:03 +00:00
parent f206410b3d
commit 36cc71d077
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2102Test.java
View File

@ -110,9 +110,9 @@ public class AMQ2102Test extends CombinationTestSupport implements UncaughtExcep
reply.setJMSCorrelationID(textMessage.getJMSCorrelationID()); reply.setJMSCorrelationID(textMessage.getJMSCorrelationID());
producer.send(replyQueue, reply); producer.send(replyQueue, reply);
debug("replied via " + replyQueue + " for message => " + textMessage.getText()); debug("replied via " + replyQueue + " for message => " + textMessage.getText() + ", " + textMessage.getJMSMessageID());
} else { } else {
debug("no reply to message => " + textMessage.getText()); debug("no reply to message => " + textMessage.getText() + ", " + textMessage.getJMSMessageID());
} }
} else { } else {
error("Consumer cannot process " + message.getClass().getSimpleName()); error("Consumer cannot process " + message.getClass().getSimpleName());
@ -349,7 +349,7 @@ public class AMQ2102Test extends CombinationTestSupport implements UncaughtExcep
TextMessage textReply = (TextMessage) reply; TextMessage textReply = (TextMessage) reply;
synchronized (messageCount) { synchronized (messageCount) {
try { try {
debug("receive reply#" + messageCount.value + " " + textReply.getText()); debug("receive reply#" + messageCount.value + " " + textReply.getText() + ", " + textReply.getJMSMessageID());
} catch (JMSException e) { } catch (JMSException e) {
error("Problem processing reply", e); error("Problem processing reply", e);
} }