File tree Expand file tree Collapse file tree 2 files changed +6
-9
lines changed
spring-boot-project/spring-boot-actuator/src
main/java/org/springframework/boot/actuate/metrics/web/reactive/server
test/java/org/springframework/boot/actuate/metrics/web/reactive/server Expand file tree Collapse file tree 2 files changed +6
-9
lines changed Original file line number Diff line number Diff line change 2222
2323import org .springframework .boot .actuate .metrics .http .Outcome ;
2424import org .springframework .http .HttpStatus ;
25- import org .springframework .http .server .reactive .AbstractServerHttpResponse ;
2625import org .springframework .http .server .reactive .ServerHttpResponse ;
2726import org .springframework .util .StringUtils ;
2827import org .springframework .web .reactive .HandlerMapping ;
@@ -164,11 +163,9 @@ public static Tag outcome(ServerWebExchange exchange) {
164163
165164 private static Integer extractStatusCode (ServerWebExchange exchange ) {
166165 ServerHttpResponse response = exchange .getResponse ();
167- if (response instanceof AbstractServerHttpResponse ) {
168- Integer statusCode = ((AbstractServerHttpResponse ) response ).getStatusCodeValue ();
169- if (statusCode != null ) {
170- return statusCode ;
171- }
166+ Integer statusCode = response .getRawStatusCode ();
167+ if (statusCode != null ) {
168+ return statusCode ;
172169 }
173170 HttpStatus status = response .getStatusCode ();
174171 return (status != null ) ? status .value () : null ;
Original file line number Diff line number Diff line change 2121import org .junit .jupiter .api .Test ;
2222
2323import org .springframework .http .HttpStatus ;
24- import org .springframework .http .server .reactive .AbstractServerHttpResponse ;
2524import org .springframework .http .server .reactive .ServerHttpRequest ;
25+ import org .springframework .http .server .reactive .ServerHttpResponse ;
2626import org .springframework .mock .http .server .reactive .MockServerHttpRequest ;
2727import org .springframework .mock .web .server .MockServerWebExchange ;
2828import org .springframework .web .reactive .HandlerMapping ;
@@ -123,9 +123,9 @@ void outcomeTagIsSuccessWhenResponseStatusIsNull() {
123123 void outcomeTagIsSuccessWhenResponseStatusIsAvailableFromUnderlyingServer () {
124124 ServerWebExchange exchange = mock (ServerWebExchange .class );
125125 ServerHttpRequest request = mock (ServerHttpRequest .class );
126- AbstractServerHttpResponse response = mock (AbstractServerHttpResponse .class );
126+ ServerHttpResponse response = mock (ServerHttpResponse .class );
127127 given (response .getStatusCode ()).willReturn (HttpStatus .OK );
128- given (response .getStatusCodeValue ()).willReturn (null );
128+ given (response .getRawStatusCode ()).willReturn (null );
129129 given (exchange .getRequest ()).willReturn (request );
130130 given (exchange .getResponse ()).willReturn (response );
131131 Tag tag = WebFluxTags .outcome (exchange );
You can’t perform that action at this time.
0 commit comments