User: dmaplesden
Date: 01/10/22 18:56:08
Modified: src/main/org/jboss/mq SpyMessageConsumer.java
Log:
Fixed race condition in receive mechanism, this time for message listeners
Revision Changes Path
1.10 +3 -4 jbossmq/src/main/org/jboss/mq/SpyMessageConsumer.java
Index: SpyMessageConsumer.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/SpyMessageConsumer.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -u -r1.9 -r1.10
--- SpyMessageConsumer.java 2001/10/15 01:42:03 1.9
+++ SpyMessageConsumer.java 2001/10/23 01:56:08 1.10
@@ -23,7 +23,7 @@
* @author Hiram Chirino ([EMAIL PROTECTED])
* @author David Maplesden ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.9 $
+ * @version $Revision: 1.10 $
*/
public class SpyMessageConsumer
implements MessageConsumer, SpyConsumer, Runnable
@@ -304,6 +304,7 @@
messages.notifyAll();
} else {
//unwanted message (due to consumer receive timing out) Nack it.
+ cat.debug( "WARNING: NACK issued. The message consumer was not
waiting for a message." );
session.connection.send( message.getAcknowledgementRequest( false
) );
}
}
@@ -328,9 +329,7 @@
break outer;
}
mes = session.connection.receive( subscription, 0 );
- }
- if ( mes == null ) {
- synchronized ( messages ) {
+ if ( mes == null ) {
waitingForMessage = true;
while ( messages.isEmpty() && !closed ) {
try {
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
