You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by kf...@apache.org on 2010/06/03 11:37:36 UTC
svn commit: r950922 -
/tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
Author: kfujino
Date: Thu Jun 3 09:37:36 2010
New Revision: 950922
URL: http://svn.apache.org/viewvc?rev=950922&view=rev
Log:
"this.channel.removeChannelListener(this.rpcChannel);" call is replaced with "this.rpcChannel.breakdown();".
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
Modified: tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java?rev=950922&r1=950921&r2=950922&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java Thu Jun 3 09:37:36 2010
@@ -228,7 +228,7 @@ public abstract class AbstractReplicated
} catch (ChannelException x) {
log.warn("Unable to send map start message.");
// remove listener from channel
- this.channel.removeChannelListener(this.rpcChannel);
+ this.rpcChannel.breakdown();
this.channel.removeChannelListener(this);
this.channel.removeMembershipListener(this);
throw new RuntimeException("Unable to start replicated map.",x);
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org