Return-Path: 
 <commons-dev-return-6732-qmlist-jakarta-archive-commons-dev=jakarta.apache.org@jakarta.apache.org>
Delivered-To: apmail-jakarta-commons-dev-archive@apache.org
Received: (qmail 7099 invoked from network); 19 Apr 2002 09:52:43 -0000
Received: from unknown (HELO nagoya.betaversion.org) (192.18.49.131)
  by daedalus.apache.org with SMTP; 19 Apr 2002 09:52:43 -0000
Received: (qmail 20977 invoked by uid 97); 19 Apr 2002 09:52:55 -0000
Delivered-To: qmlist-jakarta-archive-commons-dev@jakarta.apache.org
Received: (qmail 20910 invoked by uid 97); 19 Apr 2002 09:52:54 -0000
Mailing-List: contact commons-dev-help@jakarta.apache.org; run by ezmlm
Precedence: bulk
List-Unsubscribe: <mailto:commons-dev-unsubscribe@jakarta.apache.org>
List-Subscribe: <mailto:commons-dev-subscribe@jakarta.apache.org>
List-Help: <mailto:commons-dev-help@jakarta.apache.org>
List-Post: <mailto:commons-dev@jakarta.apache.org>
List-Id: "Jakarta Commons Developers List" <commons-dev.jakarta.apache.org>
Reply-To: "Jakarta Commons Developers List" <commons-dev@jakarta.apache.org>
Delivered-To: mailing list commons-dev@jakarta.apache.org
Received: (qmail 20899 invoked by uid 97); 19 Apr 2002 09:52:54 -0000
Date: 19 Apr 2002 09:52:38 -0000
Message-ID: <20020419095238.93491.qmail@icarus.apache.org>
From: jstrachan@apache.org
To: jakarta-commons-sandbox-cvs@apache.org
Subject: cvs commit:
 jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messagelet
 ManagerServlet.java
X-Spam-Rating: daedalus.apache.org 1.6.2 0/1000/N
X-Spam-Rating: daedalus.apache.org 1.6.2 0/1000/N

jstrachan    02/04/19 02:52:38

  Modified:    messenger/src/java/org/apache/commons/messagelet
                        ManagerServlet.java
  Log:
  Added comment to where thread-pool based subscription could be added to increase parallelism of subscriptions and message processing.
  
  Revision  Changes    Path
  1.11      +5 -2      jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messagelet/ManagerServlet.java
  
  Index: ManagerServlet.java
  ===================================================================
  RCS file: /home/cvs/jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messagelet/ManagerServlet.java,v
  retrieving revision 1.10
  retrieving revision 1.11
  diff -u -r1.10 -r1.11
  --- ManagerServlet.java	26 Feb 2002 04:12:53 -0000	1.10
  +++ ManagerServlet.java	19 Apr 2002 09:52:38 -0000	1.11
  @@ -5,7 +5,7 @@
    * version 1.1, a copy of which has been included with this distribution in
    * the LICENSE file.
    * 
  - * $Id: ManagerServlet.java,v 1.10 2002/02/26 04:12:53 jstrachan Exp $
  + * $Id: ManagerServlet.java,v 1.11 2002/04/19 09:52:38 jstrachan Exp $
    */
   package org.apache.commons.messagelet;
   
  @@ -36,7 +36,7 @@
     * and use of MessageListener beans for a given ServletContext.</p>
     *
     * @author <a href="mailto:jstrachan@apache.org">James Strachan</a>
  -  * @version $Revision: 1.10 $
  +  * @version $Revision: 1.11 $
     */
   public class ManagerServlet extends GenericServlet {
   
  @@ -187,6 +187,9 @@
               throw new ServletException( "No destination could be found for name: " + subject + " for subscription: " + subscription );
           }
   
  +        // #### at this point we may wish to create a thread pool of multiple threads
  +        // #### each consuming from the same Destination in parallel
  +        
           try {
               String selector = subscription.getSelector();
               if ( selector != null && selector.length() > 0 ) {
  
  
  

--
To unsubscribe, e-mail:   <mailto:commons-dev-unsubscribe@jakarta.apache.org>
For additional commands, e-mail: <mailto:commons-dev-help@jakarta.apache.org>