User: dmaplesden
Date: 01/12/11 14:18:09
Modified: src/main/org/jboss/mq SpyConnectionConsumer.java
Log:
Fixed bug #491613, server stops delivering messages
Revision Changes Path
1.6 +5 -4 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.5
retrieving revision 1.6
diff -u -r1.5 -r1.6
--- SpyConnectionConsumer.java 2001/08/22 00:07:18 1.5
+++ SpyConnectionConsumer.java 2001/12/11 22:18:09 1.6
@@ -19,7 +19,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.5 $
+ * @version $Revision: 1.6 $
*/
public class SpyConnectionConsumer implements javax.jms.ConnectionConsumer,
SpyConsumer, Runnable {
@@ -161,9 +161,10 @@
mesList.add(mes);
}
if(mesList.isEmpty()){
- SpyMessage mes = connection.receive( subscription, 0 );
- if ( mes == null ) {
- synchronized ( queue ) {
+ SpyMessage mes = null;
+ synchronized ( queue ) {
+ mes = connection.receive( subscription, 0 );
+ if ( mes == null ) {
waitingForMessage = true;
while ( queue.isEmpty() && !closed ) {
try {
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
