User: starksm
Date: 02/04/09 16:52:00
Modified: src/main/org/jboss/mq/server Tag: Branch_2_4
ClientConsumer.java
Log:
Check for a closed connection before waiting on messages to avoid
thread leaks.
Revision Changes Path
No revision
No revision
1.4.2.3 +7 -7 jbossmq/src/main/org/jboss/mq/server/ClientConsumer.java
Index: ClientConsumer.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jboss/mq/server/ClientConsumer.java,v
retrieving revision 1.4.2.2
retrieving revision 1.4.2.3
diff -u -r1.4.2.2 -r1.4.2.3
--- ClientConsumer.java 28 Nov 2001 06:15:32 -0000 1.4.2.2
+++ ClientConsumer.java 9 Apr 2002 23:52:00 -0000 1.4.2.3
@@ -26,7 +26,7 @@
*
* @author Hiram Chirino ([EMAIL PROTECTED])
* @created August 16, 2001
- * @version $Revision: 1.4.2.2 $
+ * @version $Revision: 1.4.2.3 $
*/
public class ClientConsumer implements Runnable
{
@@ -221,23 +221,23 @@
if( log.isTraceEnabled() )
log.trace( "" + this + "->run()" );
while ( true )
- {
-
+ {
ReceiveRequest[] job;
synchronized ( messages )
{
while ( messages.size() == 0 )
{
+ if ( closed )
+ {
+ return;
+ }
+
try
{
messages.wait();
}
catch ( InterruptedException e )
{
- }
- if ( closed )
- {
- return;
}
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
