Repository: qpid-proton Updated Branches: refs/heads/go1 d5c247084 -> 0889192a3
PROTON-1346: IOException doesn't necessarily catch java.nio.channels.UnresolvedAddressException which is thrown when server is unavailable. This will cause reactor to fail and require a client restart. changing to Exception and close transport, so client can recover from failure even if 1 server is down without stopping reactor This closes #86 Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/6afca2de Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/6afca2de Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/6afca2de Branch: refs/heads/go1 Commit: 6afca2def4858fb4a069c224b2f2041f933e8fe5 Parents: d234168 Author: Shibi <[email protected]> Authored: Mon Nov 7 11:16:21 2016 -0800 Committer: Robert Gemmell <[email protected]> Committed: Tue Nov 8 11:57:22 2016 +0000 ---------------------------------------------------------------------- .../main/java/org/apache/qpid/proton/reactor/impl/IOHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/6afca2de/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/IOHandler.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/IOHandler.java b/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/IOHandler.java index 32d1f84..178a27b 100644 --- a/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/IOHandler.java +++ b/proton-j/src/main/java/org/apache/qpid/proton/reactor/impl/IOHandler.java @@ -154,7 +154,7 @@ public class IOHandler extends BaseHandler { socketChannel.configureBlocking(false); socketChannel.connect(new InetSocketAddress(hostname, port)); socket = socketChannel.socket(); - } catch(IOException ioException) { + } catch(Exception ioException) { ErrorCondition condition = new ErrorCondition(); condition.setCondition(Symbol.getSymbol("proton:io")); condition.setDescription(ioException.getMessage()); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
