This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch sandbox/camel-3.x in repository https://gitbox.apache.org/repos/asf/camel.git
commit 1e44eb971d5806148f0af5d164a396553cc1afce Author: Jukka Aalto <jukka.aa...@insta.fi> AuthorDate: Mon Nov 26 13:54:52 2018 +0200 CAMEL-12951 reconnect exception is passed to exception handler Conflicts: components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java --- .../src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java index 737ad01..d605f0e 100644 --- a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java +++ b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java @@ -23,6 +23,7 @@ import org.apache.camel.Consumer; import org.apache.camel.Processor; import org.apache.camel.Producer; import org.apache.camel.component.ahc.AhcEndpoint; +import org.apache.camel.spi.ExceptionHandler; import org.apache.camel.spi.UriEndpoint; import org.apache.camel.spi.UriParam; import org.asynchttpclient.AsyncHttpClient; @@ -171,6 +172,10 @@ public class WsEndpoint extends AhcEndpoint { reConnect(); } catch (Exception e) { log.warn("Error re-connecting to websocket", e); + ExceptionHandler exceptionHandler = getExceptionHandler(); + if(exceptionHandler != null) { + exceptionHandler.handleException("Error re-connecting to websocket", e); + } } }