User: chirino
Date: 01/06/24 16:24:47
Modified: src/main/org/jbossmq SpyConnection.java
Log:
Hunted down and eliminated the bug that was causing the jbosstest to fail.
Revision Changes Path
1.9 +6 -2 jbossmq/src/main/org/jbossmq/SpyConnection.java
Index: SpyConnection.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/SpyConnection.java,v
retrieving revision 1.8
retrieving revision 1.9
diff -u -r1.8 -r1.9
--- SpyConnection.java 2001/06/24 04:07:16 1.8
+++ SpyConnection.java 2001/06/24 23:24:47 1.9
@@ -40,7 +40,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.8 $
+ * @version $Revision: 1.9 $
*/
public class SpyConnection implements java.io.Serializable, javax.jms.Connection {
//////////////////////////////////////////////////////////////
@@ -592,18 +592,22 @@
spyConnectionCounter--;
if( spyConnectionCounter == 0 ) {
((PooledExecutor)execeutor).shutdownAfterProcessingCurrentlyQueuedTasks();
+ execeutor = null;
+ Log.log("Shutdown the Client Thread Pool");
}
}
synchronized private void openExecutor() {
if (spyConnectionCounter == 0) {
+
+ Log.log("Starting the the Client Thread Pool");
// Using a bounded buffer of 10 tasks, at least 4 threads (started only
// when needed due to incoming requests), but allowing
// up to 100 threads if the buffer gets full.
// allowing them to die if they are not used for 1 minute.
/// clients block if both the buffer is full and all 100 threads are
busy:
- PooledExecutor pool = new PooledExecutor(new BoundedBuffer(10), 50);
+ PooledExecutor pool = new PooledExecutor(50);
pool.setMinimumPoolSize(1);
pool.setKeepAliveTime(1000 * 60 * 1);
pool.createThreads(1);
@@ -611,7 +615,7 @@
execeutor = pool;
- spyConnectionCounter++;
}
+ spyConnectionCounter++;
}
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
