User: pkendall
Date: 01/08/13 15:34:45
Modified: src/main/org/jboss/mq SpyConnectionConsumer.java
Log:
Hopefully fix MDB message delivery bug.
Revision Changes Path
1.2 +3 -3 jbossmq/src/main/org/jboss/mq/SpyConnectionConsumer.java
Index: SpyConnectionConsumer.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/SpyConnectionConsumer.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- SpyConnectionConsumer.java 2001/08/11 20:59:11 1.1
+++ SpyConnectionConsumer.java 2001/08/13 22:34:45 1.2
@@ -19,7 +19,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
public class SpyConnectionConsumer implements javax.jms.ConnectionConsumer,
SpyConsumer, Runnable {
@@ -68,7 +68,6 @@
if (closed)
return;
- connection.removeConsumer(this);
closed = true;
queue.notifyAll();
}
@@ -80,6 +79,7 @@
SpyMessage message = (SpyMessage) queue.removeFirst();
connection.send(message.getAcknowledgementRequest(false));
}
+ connection.removeConsumer(this);
}
}
@@ -109,7 +109,7 @@
if(mes == null){
synchronized(queue){
waitingForMessage = true;
- while(waitingForMessage && !closed){
+ while(queue.isEmpty() && !closed){
try{ queue.wait(); }catch(InterruptedException e){}
}
if(closed){
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
