Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/253#discussion_r216103837
--- Diff: src/java/org/apache/cassandra/streaming/async/NettyStreamingMessageSender.java
---
@@ -393,6 +393,18 @@ private Channel getOrCreateChannel()
}
}
+ private void onError(Throwable t)
+ {
+ try
+ {
+ session.onError(t).get(5, TimeUnit.MINUTES);
--- End diff --
done
---
---------------------------------------------------------------------
To unsubscribe, e-mail: pr-unsubscribe@cassandra.apache.org
For additional commands, e-mail: pr-help@cassandra.apache.org
|