chore: improve logging in safe response observer

Change-Id: I6b36da4824fee7c534bab4c3667332de2b678b4f
googleapis · Nov 4, 2024 · 19ce72f · 19ce72f
1 parent ecf4d3e
commit 19ce72f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...d-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/SafeResponseObserver.java b/...d-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/SafeResponseObserver.java
@@ -83,7 +83,7 @@ public final void onResponse(ResponseT response) {
   @Override
   public final void onError(Throwable throwable) {
     if (!isClosed.compareAndSet(false, true)) {
-      logException("Received error after the stream is closed");
+      logException("Received error after the stream is closed", throwable);
       return;
     }
 
@@ -113,6 +113,10 @@ private void logException(String message) {
     LOGGER.log(Level.WARNING, message, new IllegalStateException(message));
   }
 
+  private void logException(String message, Throwable cause) {
+    LOGGER.log(Level.WARNING, message, new IllegalStateException(message, cause));
+  }
+
   protected abstract void onStartImpl(StreamController streamController);
 
   protected abstract void onResponseImpl(ResponseT response);