From dca54e2806e2750995ad1a48267f8c2a22c49acc Mon Sep 17 00:00:00 2001 From: kfujino Date: Thu, 3 Jun 2010 09:37:36 +0000 Subject: [PATCH] "this.channel.removeChannelListener(this.rpcChannel);" call is replaced with "this.rpcChannel.breakdown();". git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@950922 13f79535-47bb-0310-9956-ffa450edef68 --- java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java b/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java index 05e2e71cb..b089dc7eb 100644 --- a/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java +++ b/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java @@ -228,7 +228,7 @@ public abstract class AbstractReplicatedMap extends ConcurrentHashMap implements } 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); -- 2.11.0