tomcat-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fha...@apache.org
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 GMT
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


Mime
View raw message