Return-Path: Delivered-To: apmail-tomcat-dev-archive@www.apache.org Received: (qmail 95160 invoked from network); 8 May 2006 13:39:57 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 8 May 2006 13:39:57 -0000 Received: (qmail 24435 invoked by uid 500); 8 May 2006 13:39:47 -0000 Delivered-To: apmail-tomcat-dev-archive@tomcat.apache.org Received: (qmail 24284 invoked by uid 500); 8 May 2006 13:39:47 -0000 Mailing-List: contact dev-help@tomcat.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: "Tomcat Developers List" Delivered-To: mailing list dev@tomcat.apache.org Received: (qmail 24247 invoked by uid 500); 8 May 2006 13:39:46 -0000 Delivered-To: apmail-jakarta-tomcat-dev@jakarta.apache.org Received: (qmail 24229 invoked by uid 99); 8 May 2006 13:39:46 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 08 May 2006 06:39:46 -0700 X-ASF-Spam-Status: No, hits=-9.4 required=10.0 tests=ALL_TRUSTED,NO_REAL_NAME X-Spam-Check-By: apache.org Received: from [209.237.227.194] (HELO minotaur.apache.org) (209.237.227.194) by apache.org (qpsmtpd/0.29) with SMTP; Mon, 08 May 2006 06:39:46 -0700 Received: (qmail 94904 invoked by uid 65534); 8 May 2006 13:39:25 -0000 Message-ID: <20060508133925.94893.qmail@minotaur.apache.org> Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r405053 - in /tomcat/container/tc5.5.x/modules/groupcom: VERSION src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java Date: Mon, 08 May 2006 13:39:23 -0000 To: tomcat-dev@jakarta.apache.org From: fhanik@apache.org X-Mailer: svnmailer-1.0.8 X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Author: fhanik Date: Mon May 8 06:39:21 2006 New Revision: 405053 URL: http://svn.apache.org/viewcvs?rev=405053&view=rev Log: async starts and stops with the sender Modified: tomcat/container/tc5.5.x/modules/groupcom/VERSION tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java Modified: tomcat/container/tc5.5.x/modules/groupcom/VERSION URL: http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/VERSION?rev=405053&r1=405052&r2=405053&view=diff ============================================================================== --- tomcat/container/tc5.5.x/modules/groupcom/VERSION (original) +++ tomcat/container/tc5.5.x/modules/groupcom/VERSION Mon May 8 06:39:21 2006 @@ -1,3 +1,6 @@ +0.9.2.1 + - remove domain from membership + - documentation updates 0.9.2.0 - message dispatch interceptor is included if no other interceptors are added so that async messaging is enabled in the default stack Modified: tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java URL: http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java?rev=405053&r1=405052&r2=405053&view=diff ============================================================================== --- tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java (original) +++ tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java Mon May 8 06:39:21 2006 @@ -104,7 +104,7 @@ //start the thread if (!run ) { synchronized (this) { - if ( !run ) { + if ( !run && ((svc & Channel.SND_TX_SEQ)==svc) ) {//only start with the sender msgDispatchThread = new Thread(this); msgDispatchThread.setName("MessageDispatchThread"); msgDispatchThread.setDaemon(true); @@ -123,7 +123,7 @@ //stop the thread if ( run ) { synchronized (this) { - if ( run ) { + if ( run && ((svc & Channel.SND_TX_SEQ)==svc)) { run = false; msgDispatchThread.interrupt(); queue.setEnabled(false); --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org For additional commands, e-mail: dev-help@tomcat.apache.org