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(); } };