Skip to content

Commit f08a9db

Browse files
dreis2211snicoll
authored andcommitted
Fix some deprecations
See gh-20388
1 parent 743671f commit f08a9db

File tree

3 files changed

+7
-7
lines changed

3 files changed

+7
-7
lines changed

spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/metrics/web/reactive/server/MetricsWebFilterTests.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ void filterAddsTagsToRegistryForExceptions() {
6969
MockServerWebExchange exchange = createExchange("/projects/spring-boot", "/projects/{project}");
7070
this.webFilter.filter(exchange, (serverWebExchange) -> Mono.error(new IllegalStateException("test error")))
7171
.onErrorResume((t) -> {
72-
exchange.getResponse().setStatusCodeValue(500);
72+
exchange.getResponse().setRawStatusCode(500);
7373
return exchange.getResponse().setComplete();
7474
}).block(Duration.ofSeconds(30));
7575
assertMetricsContainsTag("uri", "/projects/{project}");
@@ -84,7 +84,7 @@ void filterAddsNonEmptyTagsToRegistryForAnonymousExceptions() {
8484

8585
MockServerWebExchange exchange = createExchange("/projects/spring-boot", "/projects/{project}");
8686
this.webFilter.filter(exchange, (serverWebExchange) -> Mono.error(anonymous)).onErrorResume((t) -> {
87-
exchange.getResponse().setStatusCodeValue(500);
87+
exchange.getResponse().setRawStatusCode(500);
8888
return exchange.getResponse().setComplete();
8989
}).block(Duration.ofSeconds(30));
9090
assertMetricsContainsTag("uri", "/projects/{project}");
@@ -96,7 +96,7 @@ void filterAddsNonEmptyTagsToRegistryForAnonymousExceptions() {
9696
void filterAddsTagsToRegistryForExceptionsAndCommittedResponse() {
9797
MockServerWebExchange exchange = createExchange("/projects/spring-boot", "/projects/{project}");
9898
this.webFilter.filter(exchange, (serverWebExchange) -> {
99-
exchange.getResponse().setStatusCodeValue(500);
99+
exchange.getResponse().setRawStatusCode(500);
100100
return exchange.getResponse().setComplete().then(Mono.error(new IllegalStateException("test error")));
101101
}).onErrorResume((t) -> Mono.empty()).block(Duration.ofSeconds(30));
102102
assertMetricsContainsTag("uri", "/projects/{project}");

spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/metrics/web/reactive/server/WebFluxTagsTests.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ void uriTagValueIsNotFoundWhenResponseStatusIs404() {
7575

7676
@Test
7777
void uriTagToleratesCustomResponseStatus() {
78-
this.exchange.getResponse().setStatusCodeValue(601);
78+
this.exchange.getResponse().setRawStatusCode(601);
7979
Tag tag = WebFluxTags.uri(this.exchange);
8080
assertThat(tag.getValue()).isEqualTo("root");
8181
}
@@ -169,14 +169,14 @@ void outcomeTagIsServerErrorWhenResponseIs5xx() {
169169

170170
@Test
171171
void outcomeTagIsClientErrorWhenResponseIsNonStandardInClientSeries() {
172-
this.exchange.getResponse().setStatusCodeValue(490);
172+
this.exchange.getResponse().setRawStatusCode(490);
173173
Tag tag = WebFluxTags.outcome(this.exchange);
174174
assertThat(tag.getValue()).isEqualTo("CLIENT_ERROR");
175175
}
176176

177177
@Test
178178
void outcomeTagIsUnknownWhenResponseStatusIsInUnknownSeries() {
179-
this.exchange.getResponse().setStatusCodeValue(701);
179+
this.exchange.getResponse().setRawStatusCode(701);
180180
Tag tag = WebFluxTags.outcome(this.exchange);
181181
assertThat(tag.getValue()).isEqualTo("UNKNOWN");
182182
}

spring-boot-project/spring-boot/src/test/java/org/springframework/boot/web/reactive/server/AbstractReactiveWebServerFactoryTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -149,7 +149,7 @@ void sslWithValidAlias() {
149149
.clientConnector(connector).build();
150150

151151
Mono<String> result = client.post().uri("/test").contentType(MediaType.TEXT_PLAIN)
152-
.body(BodyInserters.fromObject("Hello World")).exchange()
152+
.body(BodyInserters.fromValue("Hello World")).exchange()
153153
.flatMap((response) -> response.bodyToMono(String.class));
154154

155155
StepVerifier.setDefaultTimeout(Duration.ofSeconds(30));

0 commit comments

Comments
 (0)