From: kfujino <kfujino@13f79535-47bb-0310-9956-ffa450edef68>
Date: Thu, 3 Jun 2010 09:37:36 +0000 (+0000)
Subject: "this.channel.removeChannelListener(this.rpcChannel);" call is replaced with "this... 
X-Git-Url: https://git.internetallee.de/?a=commitdiff_plain;h=dca54e2806e2750995ad1a48267f8c2a22c49acc;p=tomcat7.0

"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
---

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);