From dfa59e372ef00545ff1c8e1aed8da1c002fd6db8 Mon Sep 17 00:00:00 2001 From: Ashley Winters Date: Fri, 26 Jul 2013 10:50:28 -0500 Subject: [PATCH] Retry important messages for any IOException patch by Ashley Winters; reveiewed by yukim for CASSANDRA-5804 --- CHANGES.txt | 1 + src/java/org/apache/cassandra/net/OutboundTcpConnection.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/CHANGES.txt b/CHANGES.txt index 858bbf89f8..077a9863cd 100644 --- 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 diff --git a/src/java/org/apache/cassandra/net/OutboundTcpConnection.java b/src/java/org/apache/cassandra/net/OutboundTcpConnection.java index 648123bd5b..4edac5dd72 100644 --- 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 {