User: pkendall
Date: 01/07/31 16:45:38
Modified: src/main/org/jbossmq SpyMessageConsumer.java
Log:
Fix receiveNoWait NullPointerException error
Revision Changes Path
1.12 +3 -1 jbossmq/src/main/org/jbossmq/SpyMessageConsumer.java
Index: SpyMessageConsumer.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/SpyMessageConsumer.java,v
retrieving revision 1.11
retrieving revision 1.12
diff -u -r1.11 -r1.12
--- SpyMessageConsumer.java 2001/07/31 21:51:27 1.11
+++ SpyMessageConsumer.java 2001/07/31 23:45:38 1.12
@@ -26,7 +26,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.11 $
+ * @version $Revision: 1.12 $
*/
public class SpyMessageConsumer implements MessageConsumer, SpyConsumer {
@@ -206,6 +206,8 @@
if ( subscription.actsLikeAQueue ) {
SpyMessage msg = session.connection.receive(subscription, -1);
+ if( msg == null )
+ return null;
return preProcessMessage( msg );
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
