modify exceptionCaught

oceanbase · Apr 11, 2024 · eb23fbe · eb23fbe
1 parent d5bb24e
commit eb23fbe
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...lient-logproxy/src/main/java/com/oceanbase/clogproxy/client/connection/ClientHandler.java b/...lient-logproxy/src/main/java/com/oceanbase/clogproxy/client/connection/ClientHandler.java
@@ -462,11 +462,10 @@ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws E
 
  if (stream != null) {
  if (cause instanceof LogProxyClientException) {
+ stream.triggerException((LogProxyClientException) cause);
  if (((LogProxyClientException) cause).needStop()) {
- stream.triggerException((LogProxyClientException) cause);
  stream.stop();
  }
-
  } else {
  stream.triggerReconnect();
  }

diff --git a/oblogclient-logproxy/src/test/java/com/oceanbase/clogproxy/client/LogProxyClientTest.java b/oblogclient-logproxy/src/test/java/com/oceanbase/clogproxy/client/LogProxyClientTest.java
@@ -262,6 +262,7 @@ public void onException(LogProxyClientException e) {
 
  LogProxyClientException clientException = exception.get();
  Assert.assertNotNull(clientException);
+ LOG.info("Caught exception: {}, cause: {}", clientException, clientException.getCause());
  Assert.assertTrue(clientException.getMessage().contains("Something is going wrong"));
  }