User: user57
Date: 01/07/03 18:39:30
Modified: src/main/org/jboss/test/jmsra/test RaTest.java
Log:
Revision Changes Path
1.4 +11 -5 jbosstest/src/main/org/jboss/test/jmsra/test/RaTest.java
Index: RaTest.java
===================================================================
RCS file: /cvsroot/jboss/jbosstest/src/main/org/jboss/test/jmsra/test/RaTest.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- RaTest.java 2001/07/04 01:27:34 1.3
+++ RaTest.java 2001/07/04 01:39:30 1.4
@@ -36,7 +36,7 @@
*
* @author <a href="mailto:[EMAIL PROTECTED]";>Peter Antman</a>
* @author <a href="mailto:[EMAIL PROTECTED]";>Jason Dillon</a>
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
*/
public abstract class RaTest
extends TestCase
@@ -113,15 +113,21 @@
* @param timeout The time to wait for a message.
*
* @return Publisher.JMS_MESSAGE_NR int property or -1 if no message
- * was received.
+ * was received (or it is invalid).
*/
protected int getJmsMessage(long timeout) throws Exception {
Message msg = consumer.receive(timeout);
if (msg != null) {
System.out.println("Recived message: " + msg);
- int nr = msg.getIntProperty(Publisher.JMS_MESSAGE_NR);
- System.out.println("nr: " + nr);
- return nr;
+ try {
+ int nr = msg.getIntProperty(Publisher.JMS_MESSAGE_NR);
+ System.out.println("nr: " + nr);
+ return nr;
+ }
+ catch (Exception e) {
+ System.out.println("Invalid message, no NR");
+ return -1;
+ }
}
else {
System.out.println("NO message recived");
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
