Force a unconditional disconnect when an error happens, like dropped connections...

git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@898906 13f79535-47bb-0310-9956-ffa450edef68

diff --git a/java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java b/java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java
index 471d8dc..d7cf910 100644 (file)
--- a/java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java
+++ b/java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java
@@ -76,7 +76,12 @@ public class ReplicationTransmitter implements ChannelSender {
      */
     public void sendMessage(ChannelMessage message, Member[] destination) throws ChannelException {
         MultiPointSender sender = getTransport();
-        sender.sendMessage(destination,message);
+        try {
+            sender.sendMessage(destination,message);
+        }catch (ChannelException x) {
+            sender.disconnect();
+            throw x;
+        }
     }