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: [email protected]
For additional commands, e-mail: [email protected]
