Browse Source

Improve logging in ReactiveTypeHandler

See gh-34188
pull/34398/head
rstoyanchev 12 months ago
parent
commit
a985b73939
  1. 21
      spring-webmvc/src/main/java/org/springframework/web/servlet/mvc/method/annotation/ReactiveTypeHandler.java

21
spring-webmvc/src/main/java/org/springframework/web/servlet/mvc/method/annotation/ReactiveTypeHandler.java

@ -364,7 +364,14 @@ class ReactiveTypeHandler { @@ -364,7 +364,14 @@ class ReactiveTypeHandler {
logger.debug("Send for " + this.emitter + " failed: " + ex);
}
terminate();
try {
this.emitter.completeWithError(ex);
}
catch (Exception ex2) {
if (logger.isDebugEnabled()) {
logger.debug("Failure from emitter completeWithError: " + ex2);
}
}
return;
}
}
@ -377,14 +384,28 @@ class ReactiveTypeHandler { @@ -377,14 +384,28 @@ class ReactiveTypeHandler {
if (logger.isDebugEnabled()) {
logger.debug("Publisher for " + this.emitter + " failed: " + ex);
}
try {
this.emitter.completeWithError(ex);
}
catch (Exception ex2) {
if (logger.isDebugEnabled()) {
logger.debug("Failure from emitter completeWithError: " + ex2);
}
}
}
else {
if (logger.isTraceEnabled()) {
logger.trace("Publisher for " + this.emitter + " completed");
}
try {
this.emitter.complete();
}
catch (Exception ex2) {
if (logger.isDebugEnabled()) {
logger.debug("Failure from emitter complete: " + ex2);
}
}
}
return;
}

Loading…
Cancel
Save