User: dmaplesden
Date: 01/12/11 14:21:49
Modified: src/main/org/jboss/mq Tag: Branch_2_4
SpyConnectionConsumer.java
Log:
Fixed bug #491613, server stops delivering messages
Revision Changes Path
No revision
No revision
1.5.2.2 +5 -5 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.2.1
retrieving revision 1.5.2.2
diff -u -r1.5.2.1 -r1.5.2.2
--- SpyConnectionConsumer.java 2001/08/23 03:57:08 1.5.2.1
+++ SpyConnectionConsumer.java 2001/12/11 22:21:49 1.5.2.2
@@ -19,7 +19,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.5.2.1 $
+ * @version $Revision: 1.5.2.2 $
*/
public class SpyConnectionConsumer implements javax.jms.ConnectionConsumer,
SpyConsumer, Runnable {
@@ -148,9 +148,9 @@
while ( true ) {
//get Message
while ( mes == null ) {
- mes = connection.receive( subscription, 0 );
- if ( mes == null ) {
- synchronized ( queue ) {
+ synchronized ( queue ) {
+ mes = connection.receive( subscription, 0 );
+ if ( mes == null ) {
waitingForMessage = true;
while ( queue.isEmpty() && !closed ) {
try {
@@ -171,7 +171,7 @@
SpySession spySession = ( SpySession )serverSession.getSession();
if ( spySession.sessionConsumer == null ) {
- cat.debug( "" + this + " Session did not have a set MessageListner"
);
+ cat.debug( "" + this + " Session did not have a set MessageListener"
);
} else {
spySession.sessionConsumer.subscription = subscription;
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
