Retry important messages for any IOException

patch by Ashley Winters; reveiewed by yukim for CASSANDRA-5804
2013-07-26 10:50:28 -05:00 · 2013-07-26 10:50:28 -05:00 · dfa59e372e
parent 1810af404c
commit dfa59e372e
2 changed files with 2 additions and 1 deletions
--- a/CHANGES.txt
+++ b/CHANGES.txt
@ -1,5 +1,6 @@
 1.2.8
 * cqlsh: add collections support to COPY (CASSANDRA-5698)
+ * retry important messages for any IOException (CASSANDRA-5804)


 1.2.7
--- a/src/java/org/apache/cassandra/net/OutboundTcpConnection.java
+++ b/src/java/org/apache/cassandra/net/OutboundTcpConnection.java
@ -215,7 +215,7 @@ public class OutboundTcpConnection extends Thread

                // if the message was important, such as a repair acknowledgement, put it back on the queue
                // to retry after re-connecting.  See CASSANDRA-5393
-                if (e instanceof SocketException && qm.shouldRetry())
+                if (qm.shouldRetry())
                {
                    try
                    {