From cadfa0676c54e84b5dab2cbeec65f233d7816777 Mon Sep 17 00:00:00 2001 From: Izaaz Yunus Date: Wed, 21 Aug 2024 16:27:52 -0700 Subject: [PATCH] fix: Add exception message in callback message (#106) * fix: Add exception message in callback message --- src/main/java/com/amplitude/HttpTransport.java | 2 ++ src/test/java/com/amplitude/HttpTransportTest.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/amplitude/HttpTransport.java b/src/main/java/com/amplitude/HttpTransport.java index cc3d07a..127f8ec 100644 --- a/src/main/java/com/amplitude/HttpTransport.java +++ b/src/main/java/com/amplitude/HttpTransport.java @@ -434,6 +434,8 @@ public void run() { callbackMessage = "Unknown response status."; } } catch (Exception exception) { + callbackMessage = + "Error sending events due to the exception: " + exception + ". Message: " + exception.getMessage(); logger.error("Flush Thread Error", Utils.getStackTrace(exception)); logger.error("Error event payload", events.toString()); } finally { diff --git a/src/test/java/com/amplitude/HttpTransportTest.java b/src/test/java/com/amplitude/HttpTransportTest.java index feb7451..b93958b 100644 --- a/src/test/java/com/amplitude/HttpTransportTest.java +++ b/src/test/java/com/amplitude/HttpTransportTest.java @@ -435,7 +435,7 @@ public void testThreadTimeoutCallback() @Override public void onLogEventServerResponse(Event event, int status, String message) { resultMap.put(event, status); - assertEquals("Error send events", message); + assertEquals("Error sending events due to the exception: java.util.concurrent.TimeoutException. Message: null", message); latch.countDown(); } };