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