User: chirino
Date: 01/07/26 15:54:08
Modified: src/main/org/jbossmq/server JMSServer.java
JMSDestination.java
Log:
no message
Revision Changes Path
1.14 +2 -1 jbossmq/src/main/org/jbossmq/server/JMSServer.java
Index: JMSServer.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/server/JMSServer.java,v
retrieving revision 1.13
retrieving revision 1.14
diff -u -r1.13 -r1.14
--- JMSServer.java 2001/07/16 02:51:47 1.13
+++ JMSServer.java 2001/07/26 22:54:08 1.14
@@ -42,7 +42,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.13 $
+ * @version $Revision: 1.14 $
*/
public class JMSServer
{
@@ -99,7 +99,8 @@
executor = new PooledExecutor(25);
executor.setMinimumPoolSize(0);
executor.setKeepAliveTime(1000*30);
- executor.waitWhenBlocked();
+ executor.runWhenBlocked();
+
executor.setThreadFactory( new ThreadFactory() {
public Thread newThread(Runnable command) {
cat.debug("Creating new worker to process:
"+command);
1.7 +2 -1 jbossmq/src/main/org/jbossmq/server/JMSDestination.java
Index: JMSDestination.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/server/JMSDestination.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -r1.6 -r1.7
--- JMSDestination.java 2001/07/16 02:51:47 1.6
+++ JMSDestination.java 2001/07/26 22:54:08 1.7
@@ -29,7 +29,7 @@
* @author Norbert Lataille ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.6 $
+ * @version $Revision: 1.7 $
*/
public class JMSDestination {
@@ -53,6 +53,7 @@
// Constructor ---------------------------------------------------
JMSDestination(SpyDestination dest,ClientConsumer temporary,JMSServer server)
throws JMSException
{
+ cat =
org.apache.log4j.Category.getInstance(JMSDestination.class.getName()+":"+dest.getName());
destination=dest;
temporaryDestination=temporary;
this.server=server;
@@ -238,5 +239,5 @@
return clientId+"-"+subscriptionName;
}
- static org.apache.log4j.Category cat =
org.apache.log4j.Category.getInstance(JMSDestination.class);
+ org.apache.log4j.Category cat;
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
