You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by fh...@apache.org on 2006/05/08 15:39:23 UTC
svn commit: r405053 - in /tomcat/container/tc5.5.x/modules/groupcom: VERSION
src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
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