Skip to content

Commit 81431d9

Browse files
chore: improve logging in safe response observer (#2397)
Log the extra error
1 parent ecf4d3e commit 81431d9

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/SafeResponseObserver.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ public final void onResponse(ResponseT response) {
8383
@Override
8484
public final void onError(Throwable throwable) {
8585
if (!isClosed.compareAndSet(false, true)) {
86-
logException("Received error after the stream is closed");
86+
logException("Received error after the stream is closed", throwable);
8787
return;
8888
}
8989

@@ -113,6 +113,10 @@ private void logException(String message) {
113113
LOGGER.log(Level.WARNING, message, new IllegalStateException(message));
114114
}
115115

116+
private void logException(String message, Throwable cause) {
117+
LOGGER.log(Level.WARNING, message, new IllegalStateException(message, cause));
118+
}
119+
116120
protected abstract void onStartImpl(StreamController streamController);
117121

118122
protected abstract void onResponseImpl(ResponseT response);

0 commit comments

Comments
 (0)