Permalink
Browse files

SocketTimeoutException translated as HectorTransportException, not HT…

…imeoutException #434
  • Loading branch information...
1 parent db74f37 commit fb76ae61b272e6b3e88739fa50c446d14e785418 @sbridges sbridges committed Mar 8, 2012
@@ -30,14 +30,7 @@ public HectorException translate(Throwable original) {
} else if (original instanceof TApplicationException) {
return new HCassandraInternalException(((TApplicationException)original).getType(), original.getMessage());
} else if (original instanceof TTransportException) {
- // if the underlying cause is a scoket timeout, reflect that directly
- // TODO this may be an issue on the Cassandra side which warrants ivestigation.
- // I seem to remember these coming back as TimedOutException previously
- if ( ((TTransportException)original).getCause() instanceof SocketTimeoutException ) {
- return new HTimedOutException(original);
- } else {
- return new HectorTransportException(original);
- }
+ return new HectorTransportException(original);
} else if (original instanceof org.apache.cassandra.thrift.TimedOutException) {
return new HTimedOutException(original);
} else if (original instanceof org.apache.cassandra.thrift.InvalidRequestException) {

0 comments on commit fb76ae6

Please sign in to comment.