User: pkendall
Date: 01/07/31 14:51:27
Modified: src/main/org/jbossmq SpyMessageConsumer.java
Log:
Fix possible infinite loop with outdated messages.
Revision Changes Path
1.11 +9 -5 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.10
retrieving revision 1.11
diff -u -r1.10 -r1.11
--- SpyMessageConsumer.java 2001/07/30 09:23:14 1.10
+++ SpyMessageConsumer.java 2001/07/31 21:51:27 1.11
@@ -26,7 +26,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.10 $
+ * @version $Revision: 1.11 $
*/
public class SpyMessageConsumer implements MessageConsumer, SpyConsumer {
@@ -90,8 +90,10 @@
return null;
if ( subscription.actsLikeAQueue ) {
- SpyMessage msg = session.connection.receive(subscription, 0);
- if( msg != null ) {
+ while( true ) {
+ SpyMessage msg =
session.connection.receive(subscription, 0);
+ if( msg == null )
+ break;
Message mes = preProcessMessage( msg );
if( mes != null )
return mes;
@@ -143,8 +145,10 @@
long endTime = System.currentTimeMillis() + timeOut;
if ( subscription.actsLikeAQueue ) {
- SpyMessage msg = session.connection.receive(subscription,
timeOut);
- if( msg != null ) {
+ while( true ) {
+ SpyMessage msg =
session.connection.receive(subscription, timeOut);
+ if( msg == null )
+ break;
Message mes = preProcessMessage( msg );
if( mes != null )
return mes;
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
