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/05/26 13:58:55 UTC
svn commit: r948402 -
/tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
Author: kfujino
Date: Wed May 26 11:58:55 2010
New Revision: 948402
URL: http://svn.apache.org/viewvc?rev=948402&view=rev
Log:
Fix for BZ49343.
When ChannelException is thrown, remove listener from channel.
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=948402&r1=948401&r2=948402&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java Wed May 26 11:58:55 2010
@@ -227,6 +227,10 @@ public abstract class AbstractReplicated
broadcast(MapMessage.MSG_START, true);
} catch (ChannelException x) {
log.warn("Unable to send map start message.");
+ // remove listener from channel
+ this.channel.removeChannelListener(this.rpcChannel);
+ 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