diff options
Diffstat (limited to 'qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/TextMessageTest.java')
-rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/TextMessageTest.java | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/TextMessageTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/TextMessageTest.java index a87de8ac0c..b256b03152 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/TextMessageTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/unit/basic/TextMessageTest.java @@ -228,8 +228,16 @@ public class TextMessageTest extends QpidBrokerTestCase implements MessageListen { synchronized (received) { - _logger.info("===== received one message"); - received.add((JMSTextMessage) message); + JMSTextMessage txt = (JMSTextMessage) message; + try + { + _logger.info("===== received message " + txt.getText()); + } + catch (JMSException e) + { + // ignore + } + received.add(txt); _waitForCompletion.countDown(); } } |